expected = set([r[0] for r in curs.fetchall()])
# Get list of current screen names the list is following
- response = self.twitter_request('%s/subscribers/members.json' % self.twittername)
- current = set([x['screen_name'] for x in response['users']])
+ current = set(self.list_subscribers())
# Start by deleting, then adding the new ones
map(self.remove_subscriber, current.difference(expected))
instream.close()
return json.loads(ret)
+ def list_subscribers(self):
+ response = self.twitter_request('%s/subscribers/members.json' % self.twittername)
+ return [x['screen_name'] for x in response['users']]
+
def remove_subscriber(self, name):
print "Removing twitter user %s from list." % name
self.twitter_request('%s/subscribers/members.json' % self.twittername,'POST', {