3 require('../include/json-header.php');
5 function main($post_data) {
8 exit_with_error('DatabaseConnectionFailure');
10 $report = json_decode($post_data, true);
12 verify_slave($db, $report);
14 $commits = array_get($report, 'commits', array());
16 foreach ($commits as $commit_info) {
17 if (!array_key_exists('repository', $commit_info))
18 exit_with_error('MissingRepositoryName', array('commit' => $commit_info));
19 if (!array_key_exists('revision', $commit_info))
20 exit_with_error('MissingRevision', array('commit' => $commit_info));
21 if (!ctype_alnum($commit_info['revision']))
22 exit_with_error('InvalidRevision', array('commit' => $commit_info));
23 if (!array_key_exists('time', $commit_info))
24 exit_with_error('MissingTimestamp', array('commit' => $commit_info));
25 if (!array_key_exists('author', $commit_info) || !is_array($commit_info['author']))
26 exit_with_error('MissingAuthorOrInvalidFormat', array('commit' => $commit_info));
29 $db->begin_transaction();
30 foreach ($commits as $commit_info) {
31 $repository_id = $db->select_or_insert_row('repositories', 'repository', array('name' => $commit_info['repository']));
32 if (!$repository_id) {
33 $db->rollback_transaction();
34 exit_with_error('FailedToInsertRepository', array('commit' => $commit_info));
37 $account = array_get($commit_info['author'], 'account');
38 $committer_query = array('repository' => $repository_id, 'account' => $account);
39 $committer_data = $committer_query;
40 $name = array_get($commit_info['author'], 'name');
42 $committer_data['name'] = $name;
43 $committer_id = $db->update_or_insert_row('committers', 'committer', $committer_query, $committer_data);
45 $db->rollback_transaction();
46 exit_with_error('FailedToInsertCommitter', array('committer' => $committer_data));
49 $parent_revision = array_get($commit_info, 'parent');
51 if ($parent_revision) {
52 $parent_commit = $db->select_first_row('commits', 'commit', array('repository' => $repository_id, 'revision' => $parent_revision));
53 if (!$parent_commit) {
54 $db->rollback_transaction();
55 exit_with_error('FailedToFindParentCommit', array('commit' => $commit_info));
57 $parent_id = $parent_commit['commit_id'];
61 'repository' => $repository_id,
62 'revision' => $commit_info['revision'],
63 'parent' => $parent_id,
64 'time' => $commit_info['time'],
65 'committer' => $committer_id,
66 'message' => $commit_info['message'],
69 $db->update_or_insert_row('commits', 'commit', array('repository' => $repository_id, 'revision' => $data['revision']), $data);
71 $db->commit_transaction();
76 main($HTTP_RAW_POST_DATA);