Function getGscAccessToken

packages/db/src/gsc.ts:49–105

(projectId: string)

}

export async function getGscAccessToken(projectId: string): Promise<string> {
  const conn = await db.gscConnection.findUniqueOrThrow({
    where: { projectId },
  });

  if (
    conn.accessTokenExpiresAt &&
    conn.accessTokenExpiresAt.getTime() > Date.now() + 60_000
  ) {
    logger.info(
      { projectId, expiresAt: conn.accessTokenExpiresAt },
      'GSC using cached access token',
    );
    return decrypt(conn.accessToken);
  }

  logger.info(
    {
      projectId,
      expiresAt: conn.accessTokenExpiresAt,
      hasRefreshToken: !!conn.refreshToken,
    },
    'GSC access token expired, attempting refresh',
  );

  try {
    const { accessToken, expiresAt } = await refreshGscToken(
      decrypt(conn.refreshToken)
    );
    await db.gscConnection.update({
      where: { projectId },
      data: { accessToken: encrypt(accessToken), accessTokenExpiresAt: expiresAt },
    });
    logger.info(
      { projectId, expiresAt },
      'GSC token refreshed successfully',
    );
    return accessToken;
  } catch (error) {
    const errorMessage =
      error instanceof Error ? error.message : 'Failed to refresh token';
    logger.error(
      { err: error, projectId, errorMessage },
      'GSC token refresh failed',
    );
    await db.gscConnection.update({
      where: { projectId },
      data: {
        lastSyncStatus: 'token_expired',
        lastSyncError: errorMessage,
      },
    });
    throw new Error(
      `GSC token refresh failed for project ${projectId}: ${errorMessage}`
    );
  }
}