mirror of https://github.com/BOINC/boinc.git
140 lines
4.0 KiB
C++
140 lines
4.0 KiB
C++
// This file is part of BOINC.
|
|
// http://boinc.berkeley.edu
|
|
// Copyright (C) 2009 University of California
|
|
//
|
|
// BOINC is free software; you can redistribute it and/or modify it
|
|
// under the terms of the GNU Lesser General Public License
|
|
// as published by the Free Software Foundation,
|
|
// either version 3 of the License, or (at your option) any later version.
|
|
//
|
|
// BOINC is distributed in the hope that it will be useful,
|
|
// but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
|
|
// See the GNU Lesser General Public License for more details.
|
|
//
|
|
// You should have received a copy of the GNU Lesser General Public License
|
|
// along with BOINC. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
#ifndef _CS_NOTICE_
|
|
#define _CS_NOTICE_
|
|
|
|
// Code related to "notices", which come from
|
|
// 1) RSS feeds specified by projects and account managers
|
|
// 2) Scheduler replies (high-priority messages)
|
|
// 3) the client (MSG_USER_ALERT messages)
|
|
//
|
|
// Classes:
|
|
//
|
|
// NOTICE represents a notice of any the above types.
|
|
// Attributes include an "arrival time"; for RSS items, this is the time it
|
|
// arrived at the client, not the create time.
|
|
//
|
|
// NOTICES represents the set of all current notices.
|
|
// Each notice has a unique seqno, which is a total ordering
|
|
// compatible with increasing arrival time.
|
|
// GUI RPC allow the enumerating of notices above a given seqno.
|
|
// Seqnos are not permanent.
|
|
//
|
|
// RSS_FEED represents an RSS feed.
|
|
// The client polls each feed periodically.
|
|
//
|
|
// The last successful reply from each feed is cached on disk.
|
|
//
|
|
// Two projects may request the same feed.
|
|
// So each PROJECT has its own list of feeds.
|
|
// There's also a merged list "rss_feeds" where seqno is stored.
|
|
//
|
|
// files:
|
|
// notices/feeds.xml feed list
|
|
// notices/feeds_PROJ_URL.xml list of project feeds
|
|
// notices/RSS_URL.xml result of last fetch for a feed
|
|
// notices/archive_RSS_URL.xml archive for a feed
|
|
|
|
#include <deque>
|
|
#include <vector>
|
|
|
|
#include "miofile.h"
|
|
|
|
#include "gui_http.h"
|
|
#include "client_types.h"
|
|
#include "gui_rpc_server.h"
|
|
|
|
#include "notice.h"
|
|
|
|
struct NOTICES {
|
|
std::deque<NOTICE> notices;
|
|
// stored newest (i.e. highest seqno) message first
|
|
void write(int seqno, GUI_RPC_CONN&, bool public_only);
|
|
bool append(NOTICE&);
|
|
void init();
|
|
void init_rss();
|
|
int read_archive_file(const char* file, struct RSS_FEED*);
|
|
void write_archive(struct RSS_FEED*);
|
|
bool remove_dups(NOTICE&);
|
|
void remove_network_msg();
|
|
void clear_keep();
|
|
// prior to parsing an RSS feed, we mark all notices as "don't keep".
|
|
// We clear this flag if the notice is present in the feed.
|
|
void unkeep(const char* url);
|
|
// called after parsing an RSS feed,
|
|
// to remove notices that weren't in the feed.
|
|
void clear() {
|
|
notices.clear();
|
|
}
|
|
};
|
|
|
|
extern NOTICES notices;
|
|
|
|
struct RSS_FEED {
|
|
char url[256];
|
|
char url_base[256];
|
|
char project_name[256];
|
|
double poll_interval;
|
|
double next_poll_time;
|
|
bool found;
|
|
// temp used in garbage collection
|
|
|
|
int fetch_start();
|
|
int fetch_complete();
|
|
|
|
void write(MIOFILE&);
|
|
int parse_desc(XML_PARSER&);
|
|
int parse_items(XML_PARSER&, int&);
|
|
void feed_file_name(char*);
|
|
void archive_file_name(char*);
|
|
int read_archive_file();
|
|
};
|
|
|
|
struct RSS_FEED_OP: public GUI_HTTP_OP {
|
|
int error_num;
|
|
RSS_FEED* rfp;
|
|
|
|
RSS_FEED_OP();
|
|
virtual ~RSS_FEED_OP(){}
|
|
virtual void handle_reply(int http_op_retval);
|
|
bool poll();
|
|
};
|
|
|
|
extern RSS_FEED_OP rss_feed_op;
|
|
|
|
struct RSS_FEEDS {
|
|
std::vector<RSS_FEED> feeds;
|
|
void init();
|
|
void trigger_fetch(struct PROJ_AM*);
|
|
void update_feed_list();
|
|
RSS_FEED* lookup_url(char*);
|
|
void update_proj_am(PROJ_AM*);
|
|
void write_feed_list();
|
|
void clear() {
|
|
feeds.clear();
|
|
}
|
|
};
|
|
|
|
extern RSS_FEEDS rss_feeds;
|
|
|
|
int parse_rss_feed_descs(XML_PARSER&, std::vector<RSS_FEED>&);
|
|
void handle_sr_feeds(std::vector<RSS_FEED>&, struct PROJ_AM*);
|
|
// process the feeds in a scheduler reply
|
|
|
|
#endif
|