debug state fetch

Author: cnuss

src/services/GithubService.ts

@@ -101,6 +101,7 @@ export class GithubService {
       `Inferring identity (auth: ${auth} sha: ${tokenSha} owner: ${owner}, repo: ${repo}, workspace: ${workspace})`,
     );
 
+    // TODO Expire stored identities
     const storedIdentity = await this.identityModel.model.get(
       IdentityModel.prefix('pk', tokenSha),
       IdentityModel.prefix('sk'),
@@ -110,7 +111,7 @@ export class GithubService {
       // Terraform planfiles contain backend configurations from plan operations
       // Return the previously known identy from the plan operation
       console.log(`Found previously known identity (sha: ${tokenSha})`);
-      return storedIdentity.attrs;
+      return { ...storedIdentity.attrs, workspace: workspace || 'default' };
     }
 
     const octokit = new Octokit({ auth });

src/services/StateService.ts

@@ -83,12 +83,24 @@ export class StateService {
   };
 
   public getState = async (identity: IdentityWithToken): Promise<any> => {
+    console.log(`!!! pk search`, StateModel.prefix('pk', identity.ownerId));
+    console.log(
+      `!!! sk search`,
+      StateModel.prefix('sk', `${identity.repoId}_${identity.workspace}`),
+    );
+
     const state = await this.stateModel.model.get(
       StateModel.prefix('pk', identity.ownerId),
       StateModel.prefix('sk', `${identity.repoId}_${identity.workspace}`),
     );
 
     if (!state) {
+      console.warn(
+        `State not found (pk: ${StateModel.prefix('pk', identity.ownerId)} sk: ${StateModel.prefix(
+          'sk',
+          `${identity.repoId}_${identity.workspace}`,
+        )})`,
+      );
       return null;
     }
 
@@ -104,6 +116,7 @@ export class StateService {
     const { Body } = download;
 
     if (!Body) {
+      console.warn(`State not found in S3`);
       return null;
     }