filter.py

## some calls from the collector are refered here

#our data will be cached here
geo_data = {
  "type": "FeatureCollection",
  "features" : []
}

# a function to save the data
def saveGeoData(self, geo_data):
  with open('geo_data.json', 'a') as gd:			
    gd.write(json.dumps(geo_data, indent = 4))
    gd.close()

# a function to filter the data
def filterData(self, tweet):
  self.tweet = tweet		
  geo_data = self.geo_data

  # check if a tweet has coordinates and filter data from it

  if self.tweet['coordinates'] != None:
    print(self.tweet)

    geo_data_feature = {
      "type": "Feature",
      "geometry": self.tweet['coordinates'],
      "properties": {
        "text": self.tweet["text"],
        "created_at": self.tweet["created_at"]
        }
    }

    geo_data["features"].append(geo_data_feature)

    self.geo_data = geo_data # cache updated geodata

    self.saveGeoData(geo_data)