@@ -6,6 +6,7 @@ discard block |
||
| 6 | 6 | * @param integer $entity_guid_static |
| 7 | 7 | * @param integer $entity_guid |
| 8 | 8 | * |
| 9 | + * @return integer |
|
| 9 | 10 | */ |
| 10 | 11 | function get_forum_in_group($entity_guid_static, $entity_guid) { |
| 11 | 12 | $entity = get_entity($entity_guid); |
@@ -159,7 +160,7 @@ discard block |
||
| 159 | 160 | * @param ElggEntity $entity |
| 160 | 161 | * @param ElggUser $send_to |
| 161 | 162 | * @param string $entity_url (default value empty) |
| 162 | - * @return Success true/false |
|
| 163 | + * @return boolean true/false |
|
| 163 | 164 | */ |
| 164 | 165 | function create_digest($invoked_by, $subtype, $entity, $send_to, $entity_url = '') { |
| 165 | 166 | |
@@ -945,6 +946,7 @@ discard block |
||
| 945 | 946 | |
| 946 | 947 | /** |
| 947 | 948 | * Helper functions for digest processing queue |
| 949 | + * @param integer $user_guid |
|
| 948 | 950 | */ |
| 949 | 951 | function enqueue( $user_guid ) { |
| 950 | 952 | // add to queue |
@@ -964,6 +966,9 @@ discard block |
||
| 964 | 966 | * to get closer to 'exactly once', the digest function can enqueue failed attempts |
| 965 | 967 | * NOTE: this won't work so well with a split read-write db setup, will likely need to be done without using elgg db functions |
| 966 | 968 | */ |
| 969 | +/** |
|
| 970 | + * @return integer |
|
| 971 | + */ |
|
| 967 | 972 | function dequeue() { |
| 968 | 973 | $query_init = "SET @uid := NULL"; // mostly for termination |
| 969 | 974 | $query_delete = "DELETE FROM notification_digest_queue WHERE user_guid = @uid := user_guid LIMIT 1"; // remove a row from queue and prepare the guid to be returned |
@@ -980,6 +985,9 @@ discard block |
||
| 980 | 985 | return enqueue(0) == 0; // there is no user with guid = 0, but only one instance will successfuly insert this with user_guid being the primary key |
| 981 | 986 | } |
| 982 | 987 | |
| 988 | +/** |
|
| 989 | + * @param string $frequency |
|
| 990 | + */ |
|
| 983 | 991 | function initialize_queue( $frequency ){ |
| 984 | 992 | $dbprefix = elgg_get_config('dbprefix'); |
| 985 | 993 | |