Function parseSubscriber

packages/python/src/subscribers.ts:121–168

(
  workPath: string,
  name: string,
  config: RawSubscriber
)

}

async function parseSubscriber(
  workPath: string,
  name: string,
  config: RawSubscriber
): Promise<Subscriber> {
  if (!SUBSCRIBER_NAME_RE.test(name)) {
    throw subscriberError(
      `subscriber name "${name}" is invalid. Names must start with a letter, end with an alphanumeric character, and contain only alphanumeric characters, hyphens, and underscores`
    );
  }
  if (!config || typeof config !== 'object' || Array.isArray(config)) {
    throw subscriberError(`subscriber "${name}" must be an object`);
  }

  for (const key of Object.keys(config)) {
    if (!SUBSCRIBER_FIELD_NAMES.has(key)) {
      throw subscriberError(
        `subscriber "${name}" has unrecognized field "${key}"`
      );
    }
  }

  if (typeof config.entrypoint !== 'string') {
    throw subscriberError(
      `subscriber "${name}" must define string field "entrypoint"`
    );
  }

  const entrypoint = parseEntrypoint(name, config.entrypoint);
  const existingEntrypoint = await resolveExistingEntrypoint(
    workPath,
    entrypoint.filePath
  );
  if (!existingEntrypoint) {
    throw subscriberError(
      `subscriber "${name}" has entrypoint "${config.entrypoint}" but file "${entrypoint.filePath}" does not exist`
    );
  }

  return {
    name,
    entrypoint: existingEntrypoint,
    moduleName: entrypoint.moduleName,
    variableName: entrypoint.variableName,
    topics: parseTopics(name, config.topics),
    triggerDefaults: parseTriggerDefaults(name, config),
  };
}

function parseEntrypoint(
  name: string,