app\models(8).py

#...

class Collection(db.Model):
    #...
    
    def add_to_stream(self):
        # Initialize client and add activity to user feed
        try:
            client = stream.connect(current_app.config['STREAM_API_KEY'], current_app.config['STREAM_SECRET'])
            client.feed("User", str(self.author_id)).add_activity({'actor': client.users.create_reference(str(self.author_id)),
                                                                   'verb': 'create',
                                                                   'object': 'Collection:' + str(self.id),
                                                                   'create': self.name,
                                                                   'foreign_id': 'Collection:' + str(self.id),
                                                                   'description': self.description,
                                                                   'time': self.timestamp
                                                                   })
            return True
        except:
            # If the Stream Client throws an exception or there is a network issue
            return False

    def update_stream(self):
        # Initialize client and update activity
        try:
            client = stream.connect(current_app.config['STREAM_API_KEY'], current_app.config['STREAM_SECRET'])
            client.update_activity({'actor': client.users.create_reference(str(self.author_id)),
                                    'verb': 'create',
                                    'object': 'Collection:' + str(self.id),
                                    'create': self.name,
                                    'foreign_id': 'Collection:' + str(self.id),
                                    'description': self.description,
                                    'time': self.timestamp
                                    })
            return True
        except:
            return False

    def delete_from_stream(self):
        # Initialize client and delete activity
        try:
            client = stream.connect(current_app.config['STREAM_API_KEY'], current_app.config['STREAM_SECRET'])
            user_feed = client.feed('User', str(self.author_id))
            user_feed.remove_activity(foreign_id="Collection:" + str(self.id))
            return True
        except:
            return False