Function getValidGitLabToken

apps/web/src/lib/integrations/gitlab-service.ts:89–148

(integration: PlatformIntegration)

): string | undefined {
  const value = metadata[key];
  if (value === undefined) return undefined;
  if (typeof value !== 'string') throw new Error(`GitLab metadata ${key} must be a string`);
  return value;
}

function requireMetadataRecord(metadata: unknown): Readonly<Record<string, unknown>> {
  if (metadata === null) return {};
  if (typeof metadata !== 'object' || Array.isArray(metadata)) {
    throw new TRPCError({ code: 'UNAUTHORIZED', message: 'Invalid GitLab integration metadata' });
  }
  return { ...metadata };
}

function copyMetadataObject(
  metadata: Readonly<Record<string, unknown>>,
  key: string
): Record<string, unknown> {
  const value = metadata[key];
  if (value === undefined) return {};
  if (typeof value !== 'object' || value === null || Array.isArray(value)) {
    throw new Error(`GitLab metadata ${key} must be an object`);
  }
  return { ...value };
}

function countMetadataObjectEntries(value: unknown): number {
  return typeof value === 'object' && value !== null && !Array.isArray(value)
    ? Object.keys(value).length
    : 0;
}

function getGitLabIntegrationOwner(integration: PlatformIntegration): Owner {
  if (integration.owned_by_user_id && !integration.owned_by_organization_id) {
    return { type: 'user', id: integration.owned_by_user_id };
  }
  if (integration.owned_by_organization_id && !integration.owned_by_user_id) {
    return { type: 'org', id: integration.owned_by_organization_id };
  }
  throw new Error('GitLab integration must have exactly one owner');
}

function requireGitLabProjectId(projectId: string | number): string {
  const value = String(projectId);
  if (!/^[1-9][0-9]*$/.test(value)) {
    throw new Error('GitLab project ID must be a positive decimal');
  }
  return value;
}

/**
 * Get GitLab integration for an owner
 */
export async function getGitLabIntegration(owner: Owner): Promise<PlatformIntegration | null> {
  const ownershipCondition =
    owner.type === 'user'
      ? eq(platform_integrations.owned_by_user_id, owner.id)
      : eq(platform_integrations.owned_by_organization_id, owner.id);