···113 json_response(terms: query.terms, posts: post_uris, cursor: items.last&.cursor)
114 end
1150000000000000000116 get '/xrpc/blue.feeds.lycan.getImportStatus' do
117 headers['access-control-allow-origin'] = '*'
118
···113 json_response(terms: query.terms, posts: post_uris, cursor: items.last&.cursor)
114 end
115116+ post '/xrpc/blue.feeds.lycan.startImport' do
117+ headers['access-control-allow-origin'] = '*'
118+119+ did = get_user_did
120+ user = User.find_or_create_by!(did: did)
121+122+ if user.import_job || user.active?
123+ json_response(message: "Import has already started")
124+ else
125+ user.create_import_job!
126+127+ status 202
128+ json_response(message: "Import has been scheduled")
129+ end
130+ end
131+132 get '/xrpc/blue.feeds.lycan.getImportStatus' do
133 headers['access-control-allow-origin'] = '*'
134