ODS PubSubHubBub? Downstream API

What

The API is used in the ODS Application Downstream UI part and can be called as:

PSH.DBA.ods_cli_subscribe 
  (
    in inst_id int, 
    in hub varchar, 
    in mode varchar, 
    in topic varchar
)

Parameters

The API entry parameters are as follows:

• inst_id: the ODS instance Id integer
• hub: the hub url
• mode: 'subscribe' or 'unsubscribe'
• topic: the feed URL to subscribe

Why

The API should be called in the ODS Applications downstream UIs in order to allow push subscriptions. For ex. it is used in ODS Weblog in downstream ui.

How

When subscribed, a record into following table will be added so the UI can show them and to be possible to unsubscribe :

create table "DB"."DBA"."WA_PSH_SUBSCRIPTIONS"
(
  "PS_INST_ID" INTEGER, -- ODS instance Id
  "PS_URL" VARCHAR, -- the feed Url
  "PS_TS" TIMESTAMP, -- modification date/time
  "PS_HUB" VARCHAR, -- the Hub endpoint Url
  PRIMARY KEY ("PS_INST_ID", "PS_URL")
);

Also the ODS define it's own callback:

</psh/odscb.vsp?inst=<instanceid>

This should not be used separately as subscription API already use it.

Since every application defines own tables to import data from feeds every application should have a stored procedure in following pattern :

PSH.DBA.ods_<application type>_psh_cbk (feed_url, content, instance_id)

<application type>is one of :

• weblog,
• calendar,
• mail, etc.

same convention used in the ods rdf views and sioc data.

The above will be called when Hub pushes the feed changes, thus every application should call inside whatever logic it has to make new record.

Code

create procedure PSH.DBA.ods_cli_subscribe 
  (
    in inst_id int, 
    in hub varchar, 
    in mode varchar, 
    in topic varchar
  )
{
  declare token, subsu, callback, head, ret varchar;

  if (__proc_exists ('PSH.DBA.cli_subscribe') is null)
    signal ('42000', 'The PubSubHub package is not installed');

  if (hub is not null)
    {
      token := md5 (uuid ());

      callback := sprintf ('http://%s/psh/odscb.vsp?inst=%d', WA_GET_HOST (), inst_id);

      PSH..cli_subscribe ('dba', mode, topic, 'feed', null, token);

      subsu := sprintf ('%s?hub.callback=%U&hub.mode=%U&hub.topic=%U&hub.verify=sync&hub.verify_token=%U', hub, callback, mode, topic, token);
      commit work;	     

      ret := http_get (subsu, head);

      if (head[0] not like 'HTTP/1._ 20_ %')
	{
	  signal ('39000', 'The Hub rejects subscription request, please verify you are allowed to use it.');
	}
    }

  if (mode = 'subscribe')
    insert replacing DB.DBA.WA_PSH_SUBSCRIPTIONS (PS_INST_ID, PS_HUB, PS_URL) values (inst_id, hub, topic);
  else
    delete from DB.DBA.WA_PSH_SUBSCRIPTIONS where PS_INST_ID = inst_id and PS_URL = topic;
  commit work;	     
}
;

Related