store products in group feed

include/feed_state.hrl

@@ -9,6 +9,7 @@
         gallery,
         videos,
         bundles,
+        products,
         callback=feed_server_api,  % tmp field\part of behaviour callback state
         cached_feed,
         cached_direct,

include/groups.hrl

@@ -9,6 +9,7 @@
         created,
         owner,
         feed,
+        products,
         users_count = 0 :: integer(),   % we have to store this, counting would be very expensive and this number is sufficient for sorting and stuff
         entries_count = 0 :: integer() }).
 

src/kvs_feed.erl

@@ -180,11 +180,11 @@ purge_unverified_feeds() ->
 
 handle_notice([kvs_feed, Totype, Toid, entry, EntryId, add],
               [Fid, From, Title, Desc, Medias, EntryType, _, _, _],
-              #state{owner=Owner, feed=Feed}=State)->
+              #state{owner=Owner, feed=Feed, products=Products}=State)->
   if Owner == Toid ->
     % handle user direct feed
-    error_logger:info_msg("Add: entry ~p worker ~p feed ~p", [EntryId, Owner, Feed]),
-    add_entry(case Totype of product -> Fid; _ -> Feed end, From, {Toid, Totype}, EntryId, Title, Desc, Medias, EntryType, ""),
+    error_logger:info_msg("Add: entry ~p worker ~p feed ~p type ~p", [EntryId, Owner, Feed, Totype]),
+    add_entry(case Totype of product -> Fid; user-> Fid; {group, products}-> error_logger:info_msg("==>Group prods: ~p", [Products]),Products; _ -> Feed end, From, {Toid, Totype}, EntryId, Title, Desc, Medias, EntryType, ""),
     case Totype of
       group ->
           {ok, Group} = kvs:get(group, Toid),

src/kvs_group.erl

@@ -21,7 +21,7 @@ create(Creator, Id, Name, Desc, Publicity) ->
     Feed = kvs_feed:create(),
     Time = erlang:now(),
     Group = #group{id = Id, name = Name, description = Desc, scope = Publicity,
-                   creator = Creator, created = Time, owner = Creator, feed = Feed},
+                   creator = Creator, created = Time, owner = Creator, feed = Feed, products=kvs_feed:create()},
     error_logger:info_msg("PUT ~p", [Group]),
     kvs:put(Group),
 %    init_mq(Group),