Track history of flow ids on contacts

Author: rowanseymour

contacts/index_settings.json

@@ -153,6 +153,9 @@
                 "flow": {
                     "type": "keyword"
                 },
+                "flow_history": {
+                    "type": "integer"
+                },
                 "tickets": {
                     "type": "integer"
                 },

contacts/query.go

@@ -61,11 +61,15 @@ SELECT org_id, id, modified_on, is_active, row_to_json(t) FROM (
 		) AS groups,
 		(
 			SELECT f.uuid FROM flows_flow f WHERE f.id = contacts_contact.current_flow_id
-		) AS flow
+		) AS flow,
+		(
+			SELECT array_to_json(array_agg(DISTINCT fr.flow_id))
+			FROM flows_flowrun fr WHERE fr.contact_id = contacts_contact.id
+		) AS flow_history
 	FROM contacts_contact
 	WHERE modified_on >= $1
 	ORDER BY modified_on ASC
-	LIMIT 500000
+	LIMIT 100000
 ) t;
 `
 

indexer_test.go

@@ -104,6 +104,9 @@ func TestIndexing(t *testing.T) {
 	assertQuery(t, client, physicalName, elastic.NewMatchQuery("flow", "6d3cf1eb-546e-4fb8-a5ca-69187648fbf6"), []int64{2, 3})
 	assertQuery(t, client, physicalName, elastic.NewMatchQuery("flow", "4eea8ff1-4fe2-4ce5-92a4-0870a499973a"), []int64{4})
 
+	assertQuery(t, client, physicalName, elastic.NewMatchQuery("flow_history", 1), []int64{1, 2})
+	assertQuery(t, client, physicalName, elastic.NewMatchQuery("flow_history", 2), []int64{1})
+
 	// created_on range query
 	assertQuery(t, client, physicalName, elastic.NewRangeQuery("created_on").Gt("2017-01-01"), []int64{1, 6, 8})
 

testdb.sql

@@ -52,6 +52,15 @@ CREATE TABLE contacts_contactgroup_contacts (
     contact_id integer NOT NULL REFERENCES contacts_contact(id)
 );
 
+
+DROP TABLE IF EXISTS flows_flowrun CASCADE;
+CREATE TABLE flows_flowrun (
+    id SERIAL PRIMARY KEY,
+    uuid character varying(36) NOT NULL,
+    flow_id integer REFERENCES flows_flow(id),
+    contact_id integer REFERENCES contacts_contact(id)
+);
+
 INSERT INTO flows_flow(id, uuid, name) VALUES
 (1, '6d3cf1eb-546e-4fb8-a5ca-69187648fbf6', 'Favorites'),
 (2, '4eea8ff1-4fe2-4ce5-92a4-0870a499973a', 'Catch All');
@@ -152,3 +161,9 @@ INSERT INTO contacts_contactgroup_contacts(id, contact_id, contactgroup_id) VALU
 (1, 1, 1),
 (2, 1, 4),
 (3, 2, 4);
+
+INSERT INTO flows_flowrun(id, uuid, flow_id, contact_id) VALUES
+(1, '8b30ee61-e19d-427e-bb9f-4b8cd2c31d0c', 1, 1),
+(2, '94639979-155e-444d-95e9-a39dad64dbd5', 1, 1),
+(3, '74d918df-0e31-4547-98a9-5d765450e2ac', 2, 1),
+(4, '14fdf8fc-6e02-4759-b9be-cacc5991cd14', 1, 2);