- OpenACS 5.9 Import

sql/oracle/upgrade/upgrade-5.1.0d1-5.1.0d2.sql

+update acs_objects
+set title = 'ACS Mail Object ' || object_id
+where object_type = 'acs_mail_gc_object';
+
+update acs_objects
+set title = (select substr(header_subject,1,1000)
+             from acs_mail_bodies
+             where body_id = object_id)
+where object_type = 'acs_mail_body';
+
+update acs_objects
+set title = 'ACS Mail Multipart Object ' || object_id
+where object_type = 'acs_mail_multipart';
+
+update acs_objects
+set title = 'ACS Mail Message ' || object_id
+where object_type = 'acs_mail_link';
+
+update acs_objects
+set title = 'Queued Message ' || object_id
+where object_type = 'acs_mail_queue_message';
+
+
+@@ ../acs-mail-packages-create.sql
+
+create or replace package acs_mail_queue_message
+as
+
+ function new (
+  mail_link_id    in acs_mail_links.mail_link_id%TYPE default null,
+  body_id         in acs_mail_bodies.body_id%TYPE,
+  context_id      in acs_objects.context_id%TYPE    default null,
+  creation_date   in acs_objects.creation_date%TYPE default sysdate,
+  creation_user   in acs_objects.creation_user%TYPE default null,
+  creation_ip     in acs_objects.creation_ip%TYPE   default null,
+  object_type     in acs_objects.object_type%TYPE   default 'acs_mail_link',
+  package_id      in acs_objects.package_id%TYPE    default null
+ ) return acs_objects.object_id%TYPE;
+
+ procedure del (
+  message_id in acs_mail_links.mail_link_id%TYPE
+ );
+end acs_mail_queue_message;
+/
+show errors
+
+create or replace package body acs_mail_queue_message
+as
+
+ function new (
+  mail_link_id    in acs_mail_links.mail_link_id%TYPE default null,
+  body_id         in acs_mail_bodies.body_id%TYPE,
+  context_id      in acs_objects.context_id%TYPE    default null,
+  creation_date   in acs_objects.creation_date%TYPE default sysdate,
+  creation_user   in acs_objects.creation_user%TYPE default null,
+  creation_ip     in acs_objects.creation_ip%TYPE   default null,
+  object_type     in acs_objects.object_type%TYPE   default 'acs_mail_link',
+  package_id      in acs_objects.package_id%TYPE    default null
+ ) return acs_objects.object_id%TYPE
+ is
+     v_object_id acs_objects.object_id%TYPE;
+ begin
+     v_object_id := acs_mail_link.new (
+         mail_link_id => mail_link_id,
+	 body_id => body_id,		      
+         context_id => context_id,
+         creation_date => creation_date,
+         creation_user => creation_user,
+         creation_ip => creation_ip,
+         object_type => object_type,
+	 package_id => package_id
+     );
+
+     insert into acs_mail_queue_messages ( message_id )
+         values ( v_object_id );
+
+     return v_object_id;
+ end;
+
+ procedure del (
+  message_id in acs_mail_links.mail_link_id%TYPE
+ )
+ is
+ begin
+     delete from acs_mail_queue_messages
+         where message_id = acs_mail_queue_message.del.message_id;
+     acs_mail_link.del(message_id);
+ end;
+
+end acs_mail_queue_message;
+/
+show errors
+
+@@ ../acs-mail-nt-create.sql

sql/postgresql/upgrade/upgrade-5.1.0d1-5.1.0d2.sql

+update acs_objects
+set title = 'ACS Mail Object ' || object_id
+where object_type = 'acs_mail_gc_object';
+
+update acs_objects
+set title = (select substr(header_subject,1,1000)
+             from acs_mail_bodies
+             where body_id = object_id)
+where object_type = 'acs_mail_body';
+
+update acs_objects
+set title = 'ACS Mail Multipart Object ' || object_id
+where object_type = 'acs_mail_multipart';
+
+update acs_objects
+set title = 'ACS Mail Message ' || object_id
+where object_type = 'acs_mail_link';
+
+update acs_objects
+set title = 'Queued Message ' || object_id
+where object_type = 'acs_mail_queue_message';
+
+
+\i ../acs-mail-packages-create.sql
+
+create function acs_mail_queue_message__new (integer,integer,integer,timestamptz,integer,varchar,varchar,integer)
+returns integer as '
+declare
+	p_mail_link_id			alias for $1;    -- default null
+	p_body_id			alias for $2;
+	p_context_id			alias for $3;    -- default null
+	p_creation_date			alias for $4;    -- default now()
+	p_creation_user			alias for $5;    -- default null
+	p_creation_ip			alias for $6;    -- default null
+	p_object_type			alias for $7;    -- default acs_mail_link
+	p_package_id			alias for $8;    -- default null
+	v_mail_link_id			acs_mail_links.mail_link_id%TYPE;
+begin
+    v_mail_link_id := acs_mail_link__new (
+		p_mail_link_id,			-- mail_link_id 
+		p_body_id,			-- body_id 
+		p_context_id,			-- context_id 
+		p_creation_date,		-- creation_date 
+		p_creation_user,		-- creation_user 
+		p_creation_ip,			-- creation_ip 
+		p_object_type,			-- object_type
+		p_package_id			-- package_id
+    );
+
+    insert into acs_mail_queue_messages 
+	 ( message_id )
+    values 
+	 ( v_mail_link_id );
+
+    return v_mail_link_id;
+end;' language 'plpgsql';
+
+\i ../acs-mail-nt-create.sql

sql/postgresql/upgrade/upgrade-5.2.0d1-5.2.0d2.sql

+create or replace function acs_mail_body__body_p(integer) 
+returns boolean as '
+declare
+    p_object_id		alias for $1;
+    v_check_body_id integer;
+begin
+	select count(body_id) into v_check_body_id
+	  from acs_mail_bodies where body_id = p_object_id;
+
+     if v_check_body_id <> 0 then
+         return ''t'';
+     else
+         return ''f'';
+     end if;
+end;
+' language 'plpgsql' stable;

sql/postgresql/upgrade/upgrade-5.3.0d1-5.3.0d2.sql

+-- fix provided by Klaus Hofeditz from ]project open[ to
+-- to avoid mails to banned members
+
+create or replace function acs_mail_nt__post_request(integer,integer,boolean,varchar,text,integer,integer)
+returns integer as '
+declare
+	p_party_from		alias for $1;
+	p_party_to		alias for $2;
+	p_expand_group		alias for $3;	-- default ''f''
+	p_subject		alias for $4;
+	p_message		alias for $5;
+	p_max_retries		alias for $6;	-- default 0
+	p_package_id		alias for $7;	-- default null
+	v_header_from		acs_mail_bodies.header_from%TYPE;
+	v_header_to		acs_mail_bodies.header_to%TYPE;
+	v_body_id		acs_mail_bodies.body_id%TYPE;
+	v_item_id		cr_items.item_id%TYPE;
+	v_revision_id		cr_revisions.revision_id%TYPE;
+	v_message_id		acs_mail_queue_messages.message_id%TYPE;
+	v_header_to_rec		record;
+	v_creation_user		acs_objects.creation_user%TYPE;
+begin
+	if p_max_retries <> 0 then
+	   raise EXCEPTION '' -20000: max_retries parameter not implemented.'';
+	end if;
+
+	-- get the sender email address
+	select max(email) into v_header_from from parties where party_id = p_party_from;
+
+	-- if sender address is null, then use site default OutgoingSender
+	if v_header_from is null then
+	   	select apm__get_value(package_id, ''OutgoingSender'') into v_header_from
+		from apm_packages where package_key=''acs-kernel'';
+	end if;
+
+	-- make sure that this party is in users table. If not, let creation_user
+	-- be null to prevent integrity constraint violations on acs_objects
+	select max(user_id) into v_creation_user 
+      from users where user_id = p_party_from;
+
+	-- get the recipient email address
+	select max(email) into v_header_to from parties where party_id = p_party_to;
+
+	-- do not let any of these addresses be null
+	if v_header_from is null or v_header_to is null then
+	   raise EXCEPTION '' -20000: acs_mail_nt: cannot sent email to blank address or from blank address.'';
+	end if;
+
+	-- create a mail body with empty content
+
+	select acs_mail_body__new (
+		null,			   -- p_body_id
+		null,			   -- p_body_reply_to
+		p_party_from,		   -- p_body_from
+		now(),			   -- p_body_date
+		null,			   -- p_header_message_id
+		null,			   -- p_header_reply_to
+		p_subject,		   -- p_header_subject
+		null,			   -- p_header_from
+		null,			   -- p_header_to
+		null,			   -- p_content_item_id
+		''acs_mail_body'',	   -- p_object_type
+		now(),			   -- p_creation_date
+		v_creation_user,	   -- p_creation_user
+		null,			   -- p_creation_ip
+		null,			   -- p_context_id
+		p_package_id		   -- p_package_id
+	) into v_body_id;
+
+	-- create a CR item to stick p_message into
+
+	select content_item__new(
+        	''acs-mail message'' || v_body_id,	-- new__name
+        	null,					-- new__parent_id
+        	p_subject,				-- new__title
+        	null,					-- new__description
+        	p_message,				-- new__text
+		p_package_id				-- new__package_id
+	) into v_item_id;
+
+	-- content_item__new makes a CR revision. We need to get that revision
+	-- and make it live
+
+	select content_item__get_latest_revision (v_item_id) into v_revision_id ;
+	perform content_item__set_live_revision ( v_revision_id );
+
+	-- set the content of the message
+	perform acs_mail_body__set_content_object( v_body_id, v_item_id );
+
+	-- queue the message
+
+	select acs_mail_queue_message__new (
+		null,				-- p_mail_link_id
+		v_body_id,			-- p_body_id
+		null,				-- p_context_id
+		now(),				-- p_creation_date
+		v_creation_user,		-- p_creation_user
+		null,				-- p_creation_ip
+		''acs_mail_link'',		-- p_object_type
+		p_package_id			-- p_package_id
+	) into v_message_id;
+
+	-- now put the message into the outgoing queue
+	-- i know this seems redundant, but that''s the way it was built
+	-- the idea is that you put a generic message into the main queue
+	-- without from or to address, and then insert a copy of the message
+	-- into the outgoing_queue with the specific from and to address
+
+    if p_expand_group = ''f'' then
+		insert into acs_mail_queue_outgoing
+		( message_id, envelope_from, envelope_to )
+		values
+		( v_message_id, v_header_from, v_header_to );
+
+	else
+		-- expand the group
+		-- FIXME: need to check if this is a group and if there are members
+		--        if not, do we need to notify sender?
+
+		for v_header_to_rec in 
+			select email from parties p 
+			where party_id in (
+                           SELECT u.user_id
+                           FROM group_member_map m, membership_rels mr, users u 
+                           INNER JOIN (select member_id from group_approved_member_map where group_id = p_party_to) mm
+                           ON u.user_id = mm.member_id
+                           WHERE u.user_id = m.member_id
+                           AND m.group_id in (acs__magic_object_id(''registered_users''::CHARACTER VARYING))
+                           AND m.rel_id = mr.rel_id AND m.container_id = m.group_id
+                           AND m.rel_type::TEXT = ''membership_rel''::TEXT
+                           AND mr.member_state = ''approved''
+                        )
+                loop
+			insert into acs_mail_queue_outgoing
+			( message_id, envelope_from, envelope_to )
+			values
+			( v_message_id, v_header_from, v_header_to_rec.email );
+		end loop;
+
+    end if;
+
+	return v_message_id;
+end;' language 'plpgsql';