filter out spam posts

alex-osman · Feb 10, 2018 · 2fcd261 · 2fcd261
1 parent c362f3c
commit 2fcd261
Show file tree

Hide file tree

Showing 3 changed files with 16 additions and 9 deletions.
diff --git a/src/blockchainAPI/steemAPI.ts b/src/blockchainAPI/steemAPI.ts
@@ -11,13 +11,14 @@ export class SteemAPI {
         return new Promise((resolve, reject) => {
             steem.api.getDiscussionsByCreated({
                 "tag": tag,
-                "limit": 100
+                "limit": 10
             }, (err, result) => {
                 if (err) {
                     reject(err)
                 } else {
-                    resolve(
-                        result.map(post => ({
+                    resolve(result
+                        .filter(x => x.category === tag)
+                        .map(post => ({
                             author: post.author,
                             permlink: post.permlink,
                             created: post.created,

diff --git a/src/bot.ts b/src/bot.ts
@@ -44,9 +44,13 @@ export class Bot {
             console.log(this._blockchainAPI)
             const posts = await this._blockchainAPI.getPosts(this.communityName)
             const write = await this._database.writePosts(posts, async post => {
-                const comment = await this._broadcaster.makeComment(post)
-                const vote = await this._broadcaster.makeVote(post)
-                return { comment, vote }
+                try {
+                    const comment = await this._broadcaster.makeComment(post)
+                } catch(e) { }
+                try {
+                    const vote = await this._broadcaster.makeVote(post)
+                } catch(e) { }
+                return { }
             })
             console.log(write)
         } catch(e) {

diff --git a/src/database/sqlDatabase.ts b/src/database/sqlDatabase.ts
@@ -16,7 +16,7 @@ export class sqlDatabase {
     }
 
     async getUsers(): Promise < User[] > {
-        const users: Array < any > = await this._con.query('SELECT * FROM posts');
+        const users: Array < any > = await this._con.query('SELECT * FROM posts WHERE is_approved=1');
         return users
             .map(data => ({
                 author: data.author,
@@ -40,7 +40,7 @@ export class sqlDatabase {
     }
 
     async getPosts(): Promise < Post[] > {
-        const posts: Array < any > = await this._con.query('SELECT * FROM posts');
+        const posts: Array < any > = await this._con.query('SELECT * FROM posts WHERE is_approved=1');
         return posts.map(d => ({
             author: d.author,
             permlink: d.permlink,
@@ -52,6 +52,7 @@ export class sqlDatabase {
     }
 
     async writePosts(posts: Post[], onInsert: (post: Post) => Promise<any>): Promise<any> {
+        let count = 0;
         try {
             const insertResponses: { post: Post, result: any }[] = await Promise.all(
                 posts.map(async post => {
@@ -60,7 +61,8 @@ export class sqlDatabase {
                     }
                     try {
                         result = await this._con.query('INSERT INTO posts SET ?', [post])
-                        result.onInsert = await onInsert(post)
+                        setTimeout(() => onInsert(post), 20*1000*count)
+                        count++;
                     } catch (e) {
                         // console.log('error inserting prolly cause im there already')
                     }