]> granicus.if.org Git - ejabberd/commitdiff
Use item creation date in rsm order (#1516)
authorChristophe Romain <christophe.romain@process-one.net>
Tue, 21 Mar 2017 11:45:11 +0000 (12:45 +0100)
committerChristophe Romain <christophe.romain@process-one.net>
Tue, 21 Mar 2017 11:45:41 +0000 (12:45 +0100)
src/node_flat_sql.erl

index d3294cc685b9cc0b0494dd9eabd714344db8fc82..e47f119edc70a8681107437112df0e9b5d35056d 100644 (file)
@@ -673,20 +673,20 @@ get_items(Nidx, _From, #rsm_set{max = Max, index = IncIndex,
        case I of
            undefined when IncIndex =/= undefined ->
                case ejabberd_sql:sql_query_t(
-                      [<<"select modification from pubsub_item pi "
+                      [<<"select creation from pubsub_item pi "
                          "where exists ( select count(*) as count1 "
                          "from pubsub_item where nodeid='">>, SNidx,
-                       <<"' and modification > pi.modification having count1 = ">>,
+                       <<"' and creation > pi.creation having count1 = ">>,
                        integer_to_binary(IncIndex), <<" );">>]) of
                    {selected, [_], [[O]]} ->
-                       [<<"modification">>, <<"'", O/binary, "'">>];
+                       [<<"creation">>, <<"'", O/binary, "'">>];
                    _ ->
-                       [<<"modification">>, <<"null">>]
+                       [<<"creation">>, <<"null">>]
                end;
            undefined ->
-               [<<"modification">>, <<"null">>];
+               [<<"creation">>, <<"null">>];
            <<>> ->
-               [<<"modification">>, <<"null">>];
+               [<<"creation">>, <<"null">>];
            I ->
                [A, B] = str:tokens(ejabberd_sql:escape(I), <<"@">>),
                [A, <<"'", B/binary, "'">>]
@@ -729,8 +729,8 @@ get_items(Nidx, _From, #rsm_set{max = Max, index = IncIndex,
                                      index = Index,
                                      first = #rsm_first{
                                                 index = Index,
-                                                data = <<"modification@", F/binary>>},
-                                     last = <<"modification@", L/binary>>},
+                                                data = <<"creation@", F/binary>>},
+                                     last = <<"creation@", L/binary>>},
                    {result, {[raw_to_item(Nidx, RItem) || RItem <- RItems], RsmOut}};
                [] ->
                    {result, {[], #rsm_set{count = Count}}}