aboutsummaryrefslogtreecommitdiffstats
path: root/Zotlabs/Daemon/Convo.php
blob: e05f7539ef3fb02ef7726fa949d764e67cc4fa13 (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
<?php

namespace Zotlabs\Daemon;

use Zotlabs\Lib\Activity;
use Zotlabs\Lib\ActivityStreams;
use Zotlabs\Lib\ASCollection;

class Convo {

	static public function run($argc, $argv) {

		logger('convo invoked: ' . print_r($argv, true));

		if ($argc != 4) {
			return;
		}

		$id           = $argv[1];
		$channel_id   = intval($argv[2]);
		$contact_hash = $argv[3];

		$channel = channelx_by_n($channel_id);
		if (!$channel) {
			return;
		}

		$r = q("SELECT abook.*, xchan.* FROM abook left join xchan on abook_xchan = xchan_hash
			WHERE abook_channel = %d and abook_xchan = '%s' LIMIT 1",
			intval($channel_id),
			dbesc($contact_hash)
		);

		if (!$r) {
			return;
		}

		$contact = array_shift($r);

		$obj = new ASCollection($id, $channel);

		$messages = $obj->get();

		if (!$messages) {
			return;
		}

		foreach ($messages as $message) {
			if (is_string($message)) {
				$message = Activity::fetch($message, $channel);
			}

			// set client flag because comments will probably just be objects and not full blown activities
			// and that lets us use implied_create
			$AS = new ActivityStreams($message);
			if ($AS->is_valid() && is_array($AS->obj)) {
				$item = Activity::decode_note($AS);
				$item['item_fetched'] = true;
				Activity::store($channel, $contact['abook_xchan'], $AS, $item);
			}
		}

		return;

	}
}