diff options
author | Eugen Rochko <eugen@zeonfederated.com> | 2016-10-14 23:10:07 +0200 |
---|---|---|
committer | Eugen Rochko <eugen@zeonfederated.com> | 2016-10-14 23:10:07 +0200 |
commit | e21a3fe0cd91dfeae76bce4d58c7611e78b60fbf (patch) | |
tree | 6a4f6ceda687bbd079845daf2b1c90d15225893b /app/models/follow.rb | |
parent | 91144d46ecc1a6e2d39abe8bea2d62c5cb57aca3 (diff) |
Adding sync of follow relationships to Neo4J, accounts/suggestions API
Diffstat (limited to 'app/models/follow.rb')
-rw-r--r-- | app/models/follow.rb | 24 |
1 files changed, 24 insertions, 0 deletions
diff --git a/app/models/follow.rb b/app/models/follow.rb index 4f47580e1..1c52f24c0 100644 --- a/app/models/follow.rb +++ b/app/models/follow.rb @@ -22,4 +22,28 @@ class Follow < ApplicationRecord def title destroyed? ? "#{account.acct} is no longer following #{target_account.acct}" : "#{account.acct} started following #{target_account.acct}" end + + after_create :add_to_graph + after_destroy :remove_from_graph + + private + + def add_to_graph + neo = Neography::Rest.new + + a = neo.create_unique_node('account_index', 'Account', account_id.to_s, account_id: account_id) + b = neo.create_unique_node('account_index', 'Account', target_account_id.to_s, account_id: target_account_id) + + neo.create_unique_relationship('follow_index', 'Follow', id.to_s, 'follows', a, b) + rescue Neography::NeographyError => e + Rails.logger.error e + end + + def remove_from_graph + neo = Neography::Rest.new + rel = neo.get_relationship_index('follow_index', 'Follow', id.to_s) + neo.delete_relationship(rel) + rescue Neography::NeographyError => e + Rails.logger.error e + end end |