Fix sources

Author: SokolovskyiK

components/wordpress_com/actions/delete-post/delete-post.mjs

@@ -4,7 +4,7 @@ export default {
   key: "wordpress_com-delete-post",
   name: "Delete Post",
   description: "Deletes a post. [See the documentation](https://developer.wordpress.com/docs/api/1.1/post/sites/%24site/posts/%24post_ID/delete/)",
-  version: "0.0.2",
+  version: "0.0.1",
   type: "action",
   props: {
     wordpress,
@@ -47,7 +47,7 @@ export default {
     } catch (error) {
       wordpress.throwCustomError("Could not delete post", error, warnings);
     };
-
+  
     $.export("$summary", `Post ID “${response?.ID}” has been successfully deleted` +
        "\n- "  + warnings.join("\n- "));
   },

components/wordpress_com/common/methods.mjs

@@ -201,7 +201,7 @@ export default {
     Determines whether an error originated from your own validation code or from the API request.
     Useful for debugging and crafting more helpful error messages.
 =================================================================================================*/
-  throwCustomError(mainMessage, error, warnings) {
+  throwCustomError(mainMessage, error, warnings = []) {
 
     const thrower = error?.response?.status
       ? "API response"

components/wordpress_com/sources/new-comment/new-comment.mjs

@@ -42,6 +42,14 @@ export default {
       description: "How often to poll WordPress for new comments.",
     },
   },
+  hooks: {
+    async activate() {
+      await this.db.set("lastCommentId", null);
+      await this.run({ $ : this.wordpress._mock$() });
+    },
+  },
+
+
   async run({ $ }) {
     const warnings = [];
 
@@ -77,12 +85,6 @@ export default {
         console.log("No comments found on first run. Source initialized with no cursor.");
         return;
       }
-
-      const newest = comments[0]?.ID;
-      if (!newest) {
-        throw new Error("Failed to initialize: The latest comment does not have a valid ID.");
-      }
-
       await db.set("lastCommentId", newest);
       console.log(`Initialized lastCommentId on first run with comment ID ${newest}.`);
       return;

components/wordpress_com/sources/new-follower/new-follower.mjs

@@ -54,12 +54,6 @@ export default {
         console.log("No followers found on first run. Source initialized with no cursor.");
         return;
       }
-
-      const newest = followers[0]?.ID;
-      if (!newest) {
-        throw new Error("Failed to initialize: The latest follower does not have a valid ID.");
-      }
-
       await db.set("lastFollowerId", newest);
       console.log(`Initialized lastFollowerId on first run with follower ID ${newest}.`);
       return;

components/wordpress_com/sources/new-post/new-post.mjs

@@ -51,6 +51,41 @@ export default {
       description: "How often to poll WordPress for new posts.",
     },
   },
+  methods: {
+    getWordpressPosts($){
+
+      let response;
+        response = this.wordpress.getWordpressPosts({
+          $,
+          site:  this.site,
+          type: this.type,
+          number: this.number,
+        });
+  
+      return response;
+    }
+  },
+  hooks: {
+    async activate() {
+
+      const {
+        wordpress,
+        db,
+        type,
+      } = this;
+
+      await this.db.set("lastCommentId", null);
+
+      const response = await this.getWordpressPosts(this.wordpress._mock$);      
+  
+      const posts = (type === "attachment")
+        ? (response.media || [])
+        : (response.posts || []);
+
+      await wordpress.initialize(posts, db, "lastPostId");
+    },
+  },
+
   async run({ $ }) {
     const warnings = [];
 
@@ -59,46 +94,20 @@ export default {
       db,
       site,
       type,
-      number,
     } = this;
 
     warnings.push(...wordpress.checkDomainOrId(site));
 
-    let response;
-    try {
-      response = await wordpress.getWordpressPosts({
-        $,
-        site,
-        type,
-        number,
-      });
-
-    } catch (error) {
-      wordpress.throwCustomError("Failed to fetch posts from WordPress:", error, warnings);
-    }
+    const response = await this.getWordpressPosts($);  
 
     const posts = (type === "attachment")
       ? (response.media || [])
       : (response.posts || []);
     const lastPostId = Number(await db.get("lastPostId"));
 
-    // First run: Initialize cursor
-    if (!lastPostId) {
-      if (!posts.length) {
-        console.log("No posts found on first run. Source initialized with no cursor.");
-        return;
-      }
-
-      const newest = posts[0]?.ID;
-      if (!newest) {
-        throw new Error("Failed to initialize: The latest post does not have a valid ID.");
-      }
-
-      await db.set("lastPostId", newest);
-      console.log(`Initialized lastPostId on first run with post ID ${newest}.`);
-      return;
-    }
-
+    // Initialize if not already set
+    if (!lastPostId) await initialize(posts, db, "lastPostId");
+      
     let maxPostIdTracker = lastPostId;
 
     const newPosts = [];

components/wordpress_com/wordpress_com.app.mjs

@@ -45,6 +45,13 @@ export default {
   },
   methods: {
     ...methods,
+    _mock$(){
+      return new Proxy({}, {
+        get() {
+          return (...args) => console.log(...args);
+        },
+      });
+    },
     _baseUrl() {
       return "https://public-api.wordpress.com/rest/v1.1";
     },
@@ -155,5 +162,16 @@ export default {
         ...opts,
       });
     },
+    async initialize(subject, db, dbName){
+      if (!subject.length) {
+        console.log("No ID found on first run. Source initialized with no cursor.");
+        return false;
+      }
+      const newest = subject[0]?.ID;
+
+      await db.set(dbName, newest);
+      console.log(`Initialized ${dbName} on first run with ID ${newest}.`);
+      return true ;
+    }
   },
 };