Fix sources

Author: SokolovskyiK

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

@@ -4,7 +4,7 @@ export default {
   key: "wordpress_com-create-post",
   name: "Create New Post",
   description: "Creates a new post on a WordPress.com site. [See the documentation](https://developer.wordpress.com/docs/api/1.1/post/sites/%24site/posts/new/)",
-  version: "0.0.6",
+  version: "0.0.8",
   type: "action",
   props: {
     wordpress,

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

@@ -7,6 +7,16 @@ export default {
   version: "0.0.2",
   type: "source",
   dedupe: "unique",
+  methods: {
+    getWordpressComments($) {
+      return this.wordpress.getWordpressComments({
+        $,
+        site: this.site,
+        postId: this.postId,
+        number: this.number,
+      });
+    },
+  },
   props: {
     wordpress,
     db: "$.service.db",
@@ -44,33 +54,46 @@ export default {
   },
   hooks: {
     async activate() {
-      await this.db.set("lastCommentId", null);
-      await this.run({ $ : this.wordpress._mock$() });
+
+      const warnings = [];
+
+      const {
+        wordpress,
+        db,
+        site,
+      } = this;
+
+      warnings.push(...wordpress.checkDomainOrId(site));
+
+      if (warnings.length > 0) {
+        console.log("Warnings:\n- " + warnings.join("\n- "));
+      }
+
+      await this.db.set("lastCommentId", null); //reset
+
+      const response = await this.getWordpressComments(this.wordpress._mock$);
+
+      const comments = response.comments || [];
+
+      await wordpress.initialize(comments, db, "lastCommentId");
     },
   },
 
-
   async run({ $ }) {
     const warnings = [];
 
     const {
       wordpress,
       db,
       site,
-      postId,
-      number,
     } = this;
 
     warnings.push(...wordpress.checkDomainOrId(site));
 
     let response;
     try {
-      response = await wordpress.getWordpressComments({
-        $,
-        site,
-        postId,
-        number,
-      });
+
+      response = await this.getWordpressComments($);
 
     } catch (error) {
       wordpress.throwCustomError("Failed to fetch comments from WordPress:", error, warnings);
@@ -79,16 +102,7 @@ export default {
     const comments = response.comments || [];
     const lastCommentId = Number(await db.get("lastCommentId"));
 
-    // First run: Initialize cursor
-    if (!lastCommentId) {
-      if (!comments.length) {
-        console.log("No comments found on first run. Source initialized with no cursor.");
-        return;
-      }
-      await db.set("lastCommentId", newest);
-      console.log(`Initialized lastCommentId on first run with comment ID ${newest}.`);
-      return;
-    }
+    if (!lastCommentId)  await wordpress.initialize(comments, db, "lastCommentId");
 
     let maxCommentIdTracker = lastCommentId;
     const newComments = [];

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

@@ -7,6 +7,16 @@ export default {
   version: "0.0.2",
   type: "source",
   dedupe: "unique",
+  methods: {
+    getWordpressFollowers($) {
+
+      return this.wordpress.getWordpressFollowers({
+        $,
+        site: this.site,
+      });
+
+    },
+  },
   props: {
     wordpress,
     db: "$.service.db",
@@ -22,6 +32,33 @@ export default {
       description: "How often to poll WordPress for new followers.",
     },
   },
+  hooks: {
+    async activate() {
+
+      const warnings = [];
+
+      const {
+        wordpress,
+        db,
+        site,
+      } = this;
+
+      warnings.push(...wordpress.checkDomainOrId(site));
+
+      if (warnings.length > 0) {
+        console.log("Warnings:\n- " + warnings.join("\n- "));
+      }
+
+      await this.db.set("lastFollowerId", null); //reset
+
+      const response = await this.getWordpressFollowers(this.wordpress._mock$);
+
+      const followers = response.subscribers || [];
+
+      await wordpress.initialize(followers, db, "lastFollowerId");
+    },
+  },
+
   async run({ $ }) {
     const warnings = [];
 
@@ -35,10 +72,7 @@ export default {
 
     let response;
     try {
-      response = await wordpress.getWordpressFollowers({
-        $,
-        site,
-      });
+      response = await this.getWordpressFollowers($);
 
     } catch (error) {
       wordpress.throwCustomError("Failed to fetch followers from WordPress:", error, warnings);
@@ -48,16 +82,7 @@ export default {
 
     const lastFollowerId = Number(await db.get("lastFollowerId"));
 
-    // First run: Initialize cursor
-    if (!lastFollowerId) {
-      if (!followers.length) {
-        console.log("No followers found on first run. Source initialized with no cursor.");
-        return;
-      }
-      await db.set("lastFollowerId", newest);
-      console.log(`Initialized lastFollowerId on first run with follower ID ${newest}.`);
-      return;
-    }
+    if (!lastFollowerId) await wordpress.initialize(followers, db, "lastPostId");
 
     let maxFollowerIdTracker = lastFollowerId;
     const newFollowers = [];

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

@@ -4,7 +4,7 @@ export default {
   key: "wordpress_com-new-post",
   name: "New Post",
   description: "Emit new event for each new post published since the last run. If no new posts, emit nothing.",
-  version: "0.0.2",
+  version: "0.0.3",
   type: "source",
   dedupe: "unique",
   props: {
@@ -52,32 +52,38 @@ export default {
     },
   },
   methods: {
-    getWordpressPosts($){
-
-      let response;
-        response = this.wordpress.getWordpressPosts({
-          $,
-          site:  this.site,
-          type: this.type,
-          number: this.number,
-        });
-  
-      return response;
-    }
+    getWordpressPosts($) {
+
+      return this.wordpress.getWordpressPosts({
+        $,
+        site: this.site,
+        type: this.type,
+        number: this.number,
+      });
+
+    },
   },
   hooks: {
     async activate() {
 
-      const {
+      const warnings = []
+;      const {
         wordpress,
         db,
         type,
+        site,
       } = this;
 
-      await this.db.set("lastCommentId", null);
+      warnings.push(...wordpress.checkDomainOrId(site));
+
+      if (warnings.length > 0) {
+        console.log("Warnings:\n- " + warnings.join("\n- "));
+      }
+
+      await this.db.set("lastPostId", null); // reset
+
+      const response = await this.getWordpressPosts(this.wordpress._mock$);
 
-      const response = await this.getWordpressPosts(this.wordpress._mock$);      
-  
       const posts = (type === "attachment")
         ? (response.media || [])
         : (response.posts || []);
@@ -98,16 +104,15 @@ export default {
 
     warnings.push(...wordpress.checkDomainOrId(site));
 
-    const response = await this.getWordpressPosts($);  
+    const response = await this.getWordpressPosts($);
 
     const posts = (type === "attachment")
       ? (response.media || [])
       : (response.posts || []);
     const lastPostId = Number(await db.get("lastPostId"));
 
-    // Initialize if not already set
-    if (!lastPostId) await initialize(posts, db, "lastPostId");
-      
+    if (!lastPostId) await wordpress.initialize(posts, db, "lastPostId");
+
     let maxPostIdTracker = lastPostId;
 
     const newPosts = [];