# -*- coding: utf-8 -*-
import logging

from database.models import Page


class NeodarznetPipeline(object):

    def process_item(self, item, spider):
        try:
            page = Page.get(Page.url == item['url'])
            q = Page.update(**item).where(Page.url == item['url'])
            q.execute()
            logging.info("Update item {}".format(page))
        except Page.DoesNotExist:
            page = Page.create(**item)
            logging.info("Create item {}".format(page))
        logging.info('Item {} stored in db'.format(page))
        return item