chore: remove publishScheduledPost job and related logic

Author: m0wer

api/paidAction/lib/item.js

@@ -1,5 +1,5 @@
 import { USER_ID } from '@/lib/constants'
-import { deleteReminders, getDeleteAt, getRemindAt, getScheduleAt } from '@/lib/item'
+import { deleteReminders, getDeleteAt, getRemindAt } from '@/lib/item'
 import { parseInternalLinks } from '@/lib/url'
 
 export async function getMentions ({ text }, { me, tx }) {
@@ -46,19 +46,15 @@ export const getItemMentions = async ({ text }, { me, tx }) => {
 }
 
 export async function performBotBehavior ({ text, id }, { me, tx }) {
-  // delete any existing deleteItem, reminder, or publishScheduledPost jobs for this item
   const userId = me?.id || USER_ID.anon
   id = Number(id)
+  
   await tx.$queryRaw`
     DELETE FROM pgboss.job
-    WHERE (name = 'deleteItem' OR name = 'publishScheduledPost')
+    WHERE name = 'deleteItem'
     AND data->>'id' = ${id}::TEXT
     AND state <> 'completed'`
-  await tx.$queryRaw`
-    DELETE FROM pgboss.job
-    WHERE name = 'publishScheduledPost'
-    AND data->>'itemId' = ${id}::TEXT
-    AND state <> 'completed'`
+    
   await deleteReminders({ id, userId, models: tx })
 
   if (text) {
@@ -90,29 +86,5 @@ export async function performBotBehavior ({ text, id }, { me, tx }) {
         }
       })
     }
-
-    const scheduleAt = getScheduleAt(text)
-    if (scheduleAt) {
-      // For new items, scheduling info is set during creation
-      // For updates, we need to update the item
-      const existingItem = await tx.item.findUnique({ where: { id: Number(id) } })
-      if (existingItem && !existingItem.scheduledAt) {
-        await tx.item.update({
-          where: { id: Number(id) },
-          data: {
-            scheduledAt: scheduleAt
-          }
-        })
-      }
-
-      // Schedule the job to publish the post
-      await tx.$queryRaw`
-        INSERT INTO pgboss.job (name, data, startafter, keepuntil)
-        VALUES (
-          'publishScheduledPost',
-          jsonb_build_object('itemId', ${id}::INTEGER),
-          ${scheduleAt}::TIMESTAMP WITH TIME ZONE,
-          ${scheduleAt}::TIMESTAMP WITH TIME ZONE + interval '1 minute')`
-    }
   }
 }

api/resolvers/item.js

@@ -1095,54 +1095,6 @@ export default {
 
       return result
     },
-    publishScheduledPostNow: async (parent, { id }, { me, models }) => {
-      if (!me) {
-        throw new GqlAuthenticationError()
-      }
-
-      const item = await models.item.findUnique({
-        where: { id: Number(id) }
-      })
-
-      if (!item) {
-        throw new GqlInputError('item not found')
-      }
-
-      if (Number(item.userId) !== Number(me.id)) {
-        throw new GqlInputError('item does not belong to you')
-      }
-
-      if (!item.scheduledAt) {
-        throw new GqlInputError('item is not scheduled')
-      }
-
-      // Cancel the scheduled job
-      await models.$queryRaw`
-    DELETE FROM pgboss.job
-    WHERE name = 'publishScheduledPost'
-    AND data->>'itemId' = ${item.id}::TEXT
-    AND state <> 'completed'`
-
-      const publishTime = new Date()
-
-      // Publish immediately - keep original createdAt and scheduledAt
-      const updatedItem = await models.item.update({
-        where: { id: Number(id) },
-        data: {
-          updatedAt: publishTime
-        }
-      })
-
-      // Refresh cached views
-      await models.$executeRaw`REFRESH MATERIALIZED VIEW CONCURRENTLY hot_score_view`
-
-      // Queue side effects
-      await models.$executeRaw`
-    INSERT INTO pgboss.job (name, data, startafter)
-    VALUES ('schedulePostSideEffects', jsonb_build_object('itemId', ${item.id}::INTEGER), now())`
-
-      return updatedItem
-    }
   },
   ItemAct: {
     invoice: async (itemAct, args, { models }) => {

api/typeDefs/item.js

@@ -64,7 +64,6 @@ export default gql`
     act(id: ID!, sats: Int, act: String, hasSendWallet: Boolean): ItemActPaidAction!
     pollVote(id: ID!): PollVotePaidAction!
     toggleOutlaw(id: ID!): Item!
-    publishScheduledPostNow(id: ID!): Item!
   }
 
   type PollVoteResult {

worker/index.js

@@ -38,7 +38,6 @@ import { expireBoost } from './expireBoost'
 import { payingActionConfirmed, payingActionFailed } from './payingAction'
 import { autoDropBolt11s } from './autoDropBolt11'
 import { postToSocial } from './socialPoster'
-import { publishScheduledPost, schedulePostSideEffects } from './publishScheduledPosts'
 
 // WebSocket polyfill
 import ws from 'isomorphic-ws'
@@ -145,8 +144,6 @@ async function work () {
   await boss.work('reminder', jobWrapper(remindUser))
   await boss.work('thisDay', jobWrapper(thisDay))
   await boss.work('socialPoster', jobWrapper(postToSocial))
-  await boss.work('publishScheduledPost', jobWrapper(publishScheduledPost))
-  await boss.work('schedulePostSideEffects', jobWrapper(schedulePostSideEffects))
   await boss.work('checkWallet', jobWrapper(checkWallet))
 
   console.log('working jobs')