@@ -17,9 +17,7 @@ const config = {
17
17
18
18
const pool = new Pool ( config ) ;
19
19
20
- exports . getDeploymentCount = ( ) => {
21
-
22
- return new Promise ( ( resolve ) => {
20
+ exports . getDeploymentCount = ( ) => new Promise ( ( resolve ) => {
23
21
24
22
const selectQuery = 'SELECT count(guid) FROM deployments WHERE complete = true;' ;
25
23
@@ -30,11 +28,8 @@ exports.getDeploymentCount = () => {
30
28
resolve ( result ) ;
31
29
} ) ;
32
30
} ) ;
33
- } ;
34
-
35
- exports . getNewDeployment = ( ) => {
36
31
37
- return new Promise ( ( resolve , reject ) => {
32
+ exports . getNewDeployment = ( ) => new Promise ( ( resolve , reject ) => {
38
33
39
34
const selectQuery = "SELECT TOP 1 guid, username, repo, settings FROM deployments WHERE stage = 'init'" ;
40
35
@@ -45,14 +40,9 @@ exports.getNewDeployment = () => {
45
40
resolve ( result ) ;
46
41
} ) ;
47
42
} ) ;
48
- } ;
49
-
50
- exports . insertDeploymentStep = ( guid , stage , message ) => {
51
43
52
- return new Promise ( ( resolve , reject ) => {
44
+ exports . insertDeploymentStep = ( guid , stage , message ) => new Promise ( ( resolve , reject ) => {
53
45
54
- // TODO: INSERT INTO deployment_steps (guid, stage, message) VALUES ('8866fb1a-c64e-e711-de95-d8f17a37ed2f', 'permset', 'Permset 'nto' assigned.')
55
- // need to escape
56
46
const insertQuery = `INSERT INTO deployment_steps (guid, stage, message) VALUES ('${ guid } ', '${ stage } ', '${ message } ')` ;
57
47
58
48
pool . query ( insertQuery , ( insertErr ) => {
@@ -63,26 +53,20 @@ exports.insertDeploymentStep = (guid, stage, message) => {
63
53
resolve ( ) ;
64
54
} ) ;
65
55
} ) ;
66
- } ;
67
56
68
57
69
- exports . insertDeployment = ( insertQuery ) => {
70
-
71
- return new Promise ( ( resolve ) => {
72
-
73
- pool . query ( insertQuery , ( insertErr ) => {
74
- if ( insertErr ) {
75
- console . error ( 'insertDeployment' , insertErr ) ;
76
- resolve ( insertErr ) ;
77
- }
78
- resolve ( ) ;
79
- } ) ;
80
- } ) ;
81
- } ;
58
+ exports . insertDeployment = insertQuery => new Promise ( ( resolve ) => {
82
59
83
- exports . updateDeploymentStatus = ( guid , stage ) => {
60
+ pool . query ( insertQuery , ( insertErr ) => {
61
+ if ( insertErr ) {
62
+ console . error ( 'insertDeployment' , insertErr ) ;
63
+ resolve ( insertErr ) ;
64
+ }
65
+ resolve ( ) ;
66
+ } ) ;
67
+ } ) ;
84
68
85
- return new Promise ( ( resolve ) => {
69
+ exports . updateDeploymentStatus = ( guid , stage ) => new Promise ( ( resolve ) => {
86
70
87
71
const selectQuery = `UPDATE deployments SET stage = '${ stage } ' WHERE guid = '${ guid } '` ;
88
72
@@ -94,11 +78,8 @@ exports.updateDeploymentStatus = (guid, stage) => {
94
78
resolve ( result ) ;
95
79
} ) ;
96
80
} ) ;
97
- } ;
98
81
99
- exports . getDeploymentStatus = ( guid ) => {
100
-
101
- return new Promise ( ( resolve ) => {
82
+ exports . getDeploymentStatus = guid => new Promise ( ( resolve ) => {
102
83
103
84
const selectQuery = `SELECT deployment_steps.message, deployment_steps.created_at, deployments.complete, deployments.stage, deployments.error_message, deployments.scratch_url FROM deployment_steps INNER JOIN deployments ON deployments.guid = deployment_steps.guid WHERE deployment_steps.guid = '${ guid } ' ORDER BY created_at;` ;
104
85
@@ -110,4 +91,15 @@ exports.getDeploymentStatus = (guid) => {
110
91
resolve ( result ) ;
111
92
} ) ;
112
93
} ) ;
113
- } ;
94
+
95
+ exports . getChoices = ( ) => new Promise ( ( resolve ) => {
96
+ const selectQuery = 'SELECT count(*) as depl, repo FROM deployments WHERE complete = true GROUP BY repo ORDER BY depl DESC' ;
97
+
98
+ pool . query ( selectQuery , ( queryErr , result ) => {
99
+ if ( queryErr ) {
100
+ console . error ( 'getChoices' , queryErr ) ;
101
+ resolve ( queryErr ) ;
102
+ }
103
+ resolve ( result ) ;
104
+ } ) ;
105
+ } ) ;
0 commit comments