# -*- coding: utf-8 -*-

import json

from distribution.models.feed import FeedItem


def create_feed(data, datetime=None, wait_indexation=True):
    if isinstance(data, basestring):
        data = json.loads(data)

    if datetime:
        for item in data['items']:
            item['publication_datetime'] = datetime.strftime("%Y-%m-%dT00:00:00.0000Z")

    items = data['items']
    domain = data['domain']

    for item_data in items:
        item = FeedItem(item_data, domain)
        item.save()

        if wait_indexation:
            FeedItem.manager.wait_for_indexation(item.key)