Migrate from Octolens

export OCTOLENS_BASE_URL=https://api.rumoro.dev/compat/octolens
export OCTOLENS_API_KEY=ref_...

octolens whoami --json
octolens keywords list
octolens mentions list --source twitter

const BASE = 'https://api.rumoro.dev/compat/octolens'; // was https://app.octolens.com
const headers = { Authorization: `Bearer ${process.env.RUMORO_API_KEY}`, 'Content-Type': 'application/json' };

const res = await fetch(`${BASE}/api/v2/mentions`, { method: 'POST', headers, body: JSON.stringify({ limit: 20 }) });
const { data, pagination } = await res.json();

// node copy-from-octolens.mjs  (Node 18 or newer, nothing to install)
const FROM = { base: process.env.OCTOLENS_BASE_URL ?? 'https://app.octolens.com', key: process.env.OCTOLENS_API_KEY };
const TO = { base: process.env.RUMORO_COMPAT_URL ?? 'https://api.rumoro.dev/compat/octolens', key: process.env.RUMORO_API_KEY };

async function api(side, method, path, body) {
  const response = await fetch(`${side.base}/api/v2${path}`, {
    method,
    headers: { Authorization: `Bearer ${side.key}`, 'Content-Type': 'application/json' },
    body: body === undefined ? undefined : JSON.stringify(body),
  });
  const json = await response.json().catch(() => ({}));
  if (!response.ok) throw new Error(`${method} ${path}: ${json.error?.code ?? response.status} ${json.error?.message ?? ''}`.trim());
  return json;
}
async function attempt(label, work) {
  try { return await work(); } catch (error) { console.warn(`${label}: not copied (${error.message})`); return undefined; }
}

// Company profile. Rumoro scores relevance against it.
const company = await api(FROM, 'GET', '/org/company');
const profileFields = ['name', 'description', 'productUseCases', 'competitors', 'relevanceContext', 'relevanceGuidelines', 'twitter', 'linkedin'];
const profile = Object.fromEntries(profileFields.filter((field) => company[field]).map((field) => [field, company[field]]));
await attempt('company profile', () => api(TO, 'PATCH', '/org/company', profile));

// Keywords. Remember each new id, because the feeds refer to keywords by id.
const keywordIds = new Map();
for (const keyword of (await api(FROM, 'GET', '/keywords')).data) {
  const { id, isSubReddit, symbolSensitive, ...rest } = keyword;
  if (isSubReddit) { console.warn(`keyword ${keyword.keyword}: skipped (subreddit keywords are a global filter in Rumoro)`); continue; }
  const fields = Object.fromEntries(Object.entries(rest).filter(([, value]) => value !== null)); // drop null fields, which a create doesn't accept
  const created = await attempt(`keyword ${keyword.keyword}`, () => api(TO, 'POST', '/keywords', fields));
  if (created) keywordIds.set(String(id), String(created.id));
}

// Feeds. If none of a feed's keywords made it across, skip the feed so it doesn't suddenly match everything.
const translate = (condition) => {
  if (condition.field !== 'Keywords') return { condition, lost: false };
  const values = String(condition.values).split(',').map((value) => keywordIds.get(value.trim())).filter(Boolean);
  const excludes = String(condition.operator ?? 'in').startsWith('not');
  return { condition: { ...condition, values: values.join(',') }, lost: values.length === 0 && !excludes };
};
for (const feed of (await api(FROM, 'GET', '/feeds')).data) {
  if (feed.isDefault) continue;
  let lost = false;
  const conditions = (list) => list.map(translate).filter((item) => { lost ||= item.lost; return item.condition.field !== 'Keywords' || item.condition.values; }).map((item) => item.condition);
  const body = { name: feed.name };
  if (feed.simpleFilters) body.simpleFilters = { conditions: conditions(feed.simpleFilters.conditions) };
  if (feed.advancedFilters) body.advancedFilters = { ...feed.advancedFilters,
    groups: feed.advancedFilters.groups.map((group) => ({ ...group, conditions: conditions(group.conditions) })).filter((group) => group.conditions.length) };
  if (lost) { console.warn(`feed ${feed.name}: skipped (none of its keywords was copied)`); continue; }
  await attempt(`feed ${feed.name}`, () => api(TO, 'POST', '/feeds', body));
}

// Workspace-wide filters.
await attempt('global filters', async () => api(TO, 'PATCH', '/filters/global', await api(FROM, 'GET', '/filters/global')));
console.log('done');

OCTOLENS_API_KEY=... RUMORO_API_KEY=ref_... node copy-from-octolens.mjs