mirror of
https://github.com/evennia/evennia.git
synced 2026-04-06 16:44:08 +02:00
252 lines
No EOL
22 KiB
HTML
252 lines
No EOL
22 KiB
HTML
|
|
<!DOCTYPE html>
|
|
|
|
<html xmlns="http://www.w3.org/1999/xhtml">
|
|
<head>
|
|
<meta charset="utf-8" />
|
|
<title>evennia.server.portal.rss — Evennia 1.0-dev documentation</title>
|
|
<link rel="stylesheet" href="../../../../_static/nature.css" type="text/css" />
|
|
<link rel="stylesheet" href="../../../../_static/pygments.css" type="text/css" />
|
|
<script id="documentation_options" data-url_root="../../../../" src="../../../../_static/documentation_options.js"></script>
|
|
<script src="../../../../_static/jquery.js"></script>
|
|
<script src="../../../../_static/underscore.js"></script>
|
|
<script src="../../../../_static/doctools.js"></script>
|
|
<script src="../../../../_static/language_data.js"></script>
|
|
<link rel="shortcut icon" href="../../../../_static/favicon.ico"/>
|
|
<link rel="index" title="Index" href="../../../../genindex.html" />
|
|
<link rel="search" title="Search" href="../../../../search.html" />
|
|
</head><body>
|
|
<div class="related" role="navigation" aria-label="related navigation">
|
|
<h3>Navigation</h3>
|
|
<ul>
|
|
<li class="right" style="margin-right: 10px">
|
|
<a href="../../../../genindex.html" title="General Index"
|
|
accesskey="I">index</a></li>
|
|
<li class="right" >
|
|
<a href="../../../../py-modindex.html" title="Python Module Index"
|
|
>modules</a> |</li>
|
|
<li class="nav-item nav-item-0"><a href="../../../../index.html">Evennia 1.0-dev</a> »</li>
|
|
<li class="nav-item nav-item-1"><a href="../../../index.html" >Module code</a> »</li>
|
|
<li class="nav-item nav-item-2"><a href="../../../evennia.html" accesskey="U">evennia</a> »</li>
|
|
</ul>
|
|
</div>
|
|
|
|
<div class="document">
|
|
<div class="documentwrapper">
|
|
<div class="bodywrapper">
|
|
<div class="body" role="main">
|
|
|
|
<h1>Source code for evennia.server.portal.rss</h1><div class="highlight"><pre>
|
|
<span></span><span class="sd">"""</span>
|
|
<span class="sd">RSS parser for Evennia</span>
|
|
|
|
<span class="sd">This connects an RSS feed to an in-game Evennia channel, sending messages</span>
|
|
<span class="sd">to the channel whenever the feed updates.</span>
|
|
|
|
<span class="sd">"""</span>
|
|
<span class="kn">from</span> <span class="nn">twisted.internet</span> <span class="k">import</span> <span class="n">task</span><span class="p">,</span> <span class="n">threads</span>
|
|
<span class="kn">from</span> <span class="nn">django.conf</span> <span class="k">import</span> <span class="n">settings</span>
|
|
<span class="kn">from</span> <span class="nn">evennia.server.session</span> <span class="k">import</span> <span class="n">Session</span>
|
|
<span class="kn">from</span> <span class="nn">evennia.utils</span> <span class="k">import</span> <span class="n">logger</span>
|
|
|
|
<span class="n">RSS_ENABLED</span> <span class="o">=</span> <span class="n">settings</span><span class="o">.</span><span class="n">RSS_ENABLED</span>
|
|
<span class="c1"># RETAG = re.compile(r'<[^>]*?>')</span>
|
|
|
|
<span class="k">if</span> <span class="n">RSS_ENABLED</span><span class="p">:</span>
|
|
<span class="k">try</span><span class="p">:</span>
|
|
<span class="kn">import</span> <span class="nn">feedparser</span>
|
|
<span class="k">except</span> <span class="ne">ImportError</span><span class="p">:</span>
|
|
<span class="k">raise</span> <span class="ne">ImportError</span><span class="p">(</span>
|
|
<span class="s2">"RSS requires python-feedparser to be installed. Install or set RSS_ENABLED=False."</span>
|
|
<span class="p">)</span>
|
|
|
|
|
|
<div class="viewcode-block" id="RSSReader"><a class="viewcode-back" href="../../../../api/evennia.server.portal.rss.html#evennia.server.portal.rss.RSSReader">[docs]</a><span class="k">class</span> <span class="nc">RSSReader</span><span class="p">(</span><span class="n">Session</span><span class="p">):</span>
|
|
<span class="sd">"""</span>
|
|
<span class="sd"> A simple RSS reader using the feedparser module.</span>
|
|
|
|
<span class="sd"> """</span>
|
|
|
|
<div class="viewcode-block" id="RSSReader.__init__"><a class="viewcode-back" href="../../../../api/evennia.server.portal.rss.html#evennia.server.portal.rss.RSSReader.__init__">[docs]</a> <span class="k">def</span> <span class="nf">__init__</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">factory</span><span class="p">,</span> <span class="n">url</span><span class="p">,</span> <span class="n">rate</span><span class="p">):</span>
|
|
<span class="sd">"""</span>
|
|
<span class="sd"> Initialize the reader.</span>
|
|
|
|
<span class="sd"> Args:</span>
|
|
<span class="sd"> factory (RSSFactory): The protocol factory.</span>
|
|
<span class="sd"> url (str): The RSS url.</span>
|
|
<span class="sd"> rate (int): The seconds between RSS lookups.</span>
|
|
|
|
<span class="sd"> """</span>
|
|
<span class="bp">self</span><span class="o">.</span><span class="n">url</span> <span class="o">=</span> <span class="n">url</span>
|
|
<span class="bp">self</span><span class="o">.</span><span class="n">rate</span> <span class="o">=</span> <span class="n">rate</span>
|
|
<span class="bp">self</span><span class="o">.</span><span class="n">factory</span> <span class="o">=</span> <span class="n">factory</span>
|
|
<span class="bp">self</span><span class="o">.</span><span class="n">old_entries</span> <span class="o">=</span> <span class="p">{}</span></div>
|
|
|
|
<div class="viewcode-block" id="RSSReader.get_new"><a class="viewcode-back" href="../../../../api/evennia.server.portal.rss.html#evennia.server.portal.rss.RSSReader.get_new">[docs]</a> <span class="k">def</span> <span class="nf">get_new</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span>
|
|
<span class="sd">"""</span>
|
|
<span class="sd"> Returns list of new items.</span>
|
|
|
|
<span class="sd"> """</span>
|
|
<span class="n">feed</span> <span class="o">=</span> <span class="n">feedparser</span><span class="o">.</span><span class="n">parse</span><span class="p">(</span><span class="bp">self</span><span class="o">.</span><span class="n">url</span><span class="p">)</span>
|
|
<span class="n">new_entries</span> <span class="o">=</span> <span class="p">[]</span>
|
|
<span class="k">for</span> <span class="n">entry</span> <span class="ow">in</span> <span class="n">feed</span><span class="p">[</span><span class="s2">"entries"</span><span class="p">]:</span>
|
|
<span class="n">idval</span> <span class="o">=</span> <span class="n">entry</span><span class="p">[</span><span class="s2">"id"</span><span class="p">]</span> <span class="o">+</span> <span class="n">entry</span><span class="o">.</span><span class="n">get</span><span class="p">(</span><span class="s2">"updated"</span><span class="p">,</span> <span class="s2">""</span><span class="p">)</span>
|
|
<span class="k">if</span> <span class="n">idval</span> <span class="ow">not</span> <span class="ow">in</span> <span class="bp">self</span><span class="o">.</span><span class="n">old_entries</span><span class="p">:</span>
|
|
<span class="bp">self</span><span class="o">.</span><span class="n">old_entries</span><span class="p">[</span><span class="n">idval</span><span class="p">]</span> <span class="o">=</span> <span class="n">entry</span>
|
|
<span class="n">new_entries</span><span class="o">.</span><span class="n">append</span><span class="p">(</span><span class="n">entry</span><span class="p">)</span>
|
|
<span class="k">return</span> <span class="n">new_entries</span></div>
|
|
|
|
<div class="viewcode-block" id="RSSReader.disconnect"><a class="viewcode-back" href="../../../../api/evennia.server.portal.rss.html#evennia.server.portal.rss.RSSReader.disconnect">[docs]</a> <span class="k">def</span> <span class="nf">disconnect</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">reason</span><span class="o">=</span><span class="kc">None</span><span class="p">):</span>
|
|
<span class="sd">"""</span>
|
|
<span class="sd"> Disconnect from feed.</span>
|
|
|
|
<span class="sd"> Args:</span>
|
|
<span class="sd"> reason (str, optional): Motivation for the disconnect.</span>
|
|
|
|
<span class="sd"> """</span>
|
|
<span class="k">if</span> <span class="bp">self</span><span class="o">.</span><span class="n">factory</span><span class="o">.</span><span class="n">task</span> <span class="ow">and</span> <span class="bp">self</span><span class="o">.</span><span class="n">factory</span><span class="o">.</span><span class="n">task</span><span class="o">.</span><span class="n">running</span><span class="p">:</span>
|
|
<span class="bp">self</span><span class="o">.</span><span class="n">factory</span><span class="o">.</span><span class="n">task</span><span class="o">.</span><span class="n">stop</span><span class="p">()</span>
|
|
<span class="bp">self</span><span class="o">.</span><span class="n">sessionhandler</span><span class="o">.</span><span class="n">disconnect</span><span class="p">(</span><span class="bp">self</span><span class="p">)</span></div>
|
|
|
|
<span class="k">def</span> <span class="nf">_callback</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">new_entries</span><span class="p">,</span> <span class="n">init</span><span class="p">):</span>
|
|
<span class="sd">"""</span>
|
|
<span class="sd"> Called when RSS returns.</span>
|
|
|
|
<span class="sd"> Args:</span>
|
|
<span class="sd"> new_entries (list): List of new RSS entries since last.</span>
|
|
<span class="sd"> init (bool): If this is a startup operation (at which</span>
|
|
<span class="sd"> point all entries are considered new).</span>
|
|
|
|
<span class="sd"> """</span>
|
|
<span class="k">if</span> <span class="ow">not</span> <span class="n">init</span><span class="p">:</span>
|
|
<span class="c1"># for initialization we just ignore old entries</span>
|
|
<span class="k">for</span> <span class="n">entry</span> <span class="ow">in</span> <span class="nb">reversed</span><span class="p">(</span><span class="n">new_entries</span><span class="p">):</span>
|
|
<span class="bp">self</span><span class="o">.</span><span class="n">data_in</span><span class="p">(</span><span class="n">entry</span><span class="p">)</span>
|
|
|
|
<div class="viewcode-block" id="RSSReader.data_in"><a class="viewcode-back" href="../../../../api/evennia.server.portal.rss.html#evennia.server.portal.rss.RSSReader.data_in">[docs]</a> <span class="k">def</span> <span class="nf">data_in</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">text</span><span class="o">=</span><span class="kc">None</span><span class="p">,</span> <span class="o">**</span><span class="n">kwargs</span><span class="p">):</span>
|
|
<span class="sd">"""</span>
|
|
<span class="sd"> Data RSS -> Evennia.</span>
|
|
|
|
<span class="sd"> Keyword Args:</span>
|
|
<span class="sd"> text (str): Incoming text</span>
|
|
<span class="sd"> kwargs (any): Options from protocol.</span>
|
|
|
|
<span class="sd"> """</span>
|
|
<span class="bp">self</span><span class="o">.</span><span class="n">sessionhandler</span><span class="o">.</span><span class="n">data_in</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">bot_data_in</span><span class="o">=</span><span class="n">text</span><span class="p">,</span> <span class="o">**</span><span class="n">kwargs</span><span class="p">)</span></div>
|
|
|
|
<span class="k">def</span> <span class="nf">_errback</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">fail</span><span class="p">):</span>
|
|
<span class="s2">"Report error"</span>
|
|
<span class="n">logger</span><span class="o">.</span><span class="n">log_err</span><span class="p">(</span><span class="s2">"RSS feed error: </span><span class="si">%s</span><span class="s2">"</span> <span class="o">%</span> <span class="n">fail</span><span class="o">.</span><span class="n">value</span><span class="p">)</span>
|
|
|
|
<div class="viewcode-block" id="RSSReader.update"><a class="viewcode-back" href="../../../../api/evennia.server.portal.rss.html#evennia.server.portal.rss.RSSReader.update">[docs]</a> <span class="k">def</span> <span class="nf">update</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">init</span><span class="o">=</span><span class="kc">False</span><span class="p">):</span>
|
|
<span class="sd">"""</span>
|
|
<span class="sd"> Request the latest version of feed.</span>
|
|
|
|
<span class="sd"> Args:</span>
|
|
<span class="sd"> init (bool, optional): If this is an initialization call</span>
|
|
<span class="sd"> or not (during init, all entries are conidered new).</span>
|
|
|
|
<span class="sd"> Notes:</span>
|
|
<span class="sd"> This call is done in a separate thread to avoid blocking</span>
|
|
<span class="sd"> on slow connections.</span>
|
|
|
|
<span class="sd"> """</span>
|
|
<span class="k">return</span> <span class="p">(</span>
|
|
<span class="n">threads</span><span class="o">.</span><span class="n">deferToThread</span><span class="p">(</span><span class="bp">self</span><span class="o">.</span><span class="n">get_new</span><span class="p">)</span>
|
|
<span class="o">.</span><span class="n">addCallback</span><span class="p">(</span><span class="bp">self</span><span class="o">.</span><span class="n">_callback</span><span class="p">,</span> <span class="n">init</span><span class="p">)</span>
|
|
<span class="o">.</span><span class="n">addErrback</span><span class="p">(</span><span class="bp">self</span><span class="o">.</span><span class="n">_errback</span><span class="p">)</span>
|
|
<span class="p">)</span></div></div>
|
|
|
|
|
|
<div class="viewcode-block" id="RSSBotFactory"><a class="viewcode-back" href="../../../../api/evennia.server.portal.rss.html#evennia.server.portal.rss.RSSBotFactory">[docs]</a><span class="k">class</span> <span class="nc">RSSBotFactory</span><span class="p">(</span><span class="nb">object</span><span class="p">):</span>
|
|
<span class="sd">"""</span>
|
|
<span class="sd"> Initializes new bots.</span>
|
|
<span class="sd"> """</span>
|
|
|
|
<div class="viewcode-block" id="RSSBotFactory.__init__"><a class="viewcode-back" href="../../../../api/evennia.server.portal.rss.html#evennia.server.portal.rss.RSSBotFactory.__init__">[docs]</a> <span class="k">def</span> <span class="nf">__init__</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">sessionhandler</span><span class="p">,</span> <span class="n">uid</span><span class="o">=</span><span class="kc">None</span><span class="p">,</span> <span class="n">url</span><span class="o">=</span><span class="kc">None</span><span class="p">,</span> <span class="n">rate</span><span class="o">=</span><span class="kc">None</span><span class="p">):</span>
|
|
<span class="sd">"""</span>
|
|
<span class="sd"> Initialize the bot.</span>
|
|
|
|
<span class="sd"> Args:</span>
|
|
<span class="sd"> sessionhandler (PortalSessionHandler): The main sessionhandler object.</span>
|
|
<span class="sd"> uid (int): User id for the bot.</span>
|
|
<span class="sd"> url (str): The RSS URL.</span>
|
|
<span class="sd"> rate (int): How often for the RSS to request the latest RSS entries.</span>
|
|
|
|
<span class="sd"> """</span>
|
|
<span class="bp">self</span><span class="o">.</span><span class="n">sessionhandler</span> <span class="o">=</span> <span class="n">sessionhandler</span>
|
|
<span class="bp">self</span><span class="o">.</span><span class="n">url</span> <span class="o">=</span> <span class="n">url</span>
|
|
<span class="bp">self</span><span class="o">.</span><span class="n">rate</span> <span class="o">=</span> <span class="n">rate</span>
|
|
<span class="bp">self</span><span class="o">.</span><span class="n">uid</span> <span class="o">=</span> <span class="n">uid</span>
|
|
<span class="bp">self</span><span class="o">.</span><span class="n">bot</span> <span class="o">=</span> <span class="n">RSSReader</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">url</span><span class="p">,</span> <span class="n">rate</span><span class="p">)</span>
|
|
<span class="bp">self</span><span class="o">.</span><span class="n">task</span> <span class="o">=</span> <span class="kc">None</span></div>
|
|
|
|
<div class="viewcode-block" id="RSSBotFactory.start"><a class="viewcode-back" href="../../../../api/evennia.server.portal.rss.html#evennia.server.portal.rss.RSSBotFactory.start">[docs]</a> <span class="k">def</span> <span class="nf">start</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span>
|
|
<span class="sd">"""</span>
|
|
<span class="sd"> Called by portalsessionhandler. Starts the bot.</span>
|
|
<span class="sd"> """</span>
|
|
|
|
<span class="k">def</span> <span class="nf">errback</span><span class="p">(</span><span class="n">fail</span><span class="p">):</span>
|
|
<span class="n">logger</span><span class="o">.</span><span class="n">log_err</span><span class="p">(</span><span class="n">fail</span><span class="o">.</span><span class="n">value</span><span class="p">)</span>
|
|
|
|
<span class="c1"># set up session and connect it to sessionhandler</span>
|
|
<span class="bp">self</span><span class="o">.</span><span class="n">bot</span><span class="o">.</span><span class="n">init_session</span><span class="p">(</span><span class="s2">"rssbot"</span><span class="p">,</span> <span class="bp">self</span><span class="o">.</span><span class="n">url</span><span class="p">,</span> <span class="bp">self</span><span class="o">.</span><span class="n">sessionhandler</span><span class="p">)</span>
|
|
<span class="bp">self</span><span class="o">.</span><span class="n">bot</span><span class="o">.</span><span class="n">uid</span> <span class="o">=</span> <span class="bp">self</span><span class="o">.</span><span class="n">uid</span>
|
|
<span class="bp">self</span><span class="o">.</span><span class="n">bot</span><span class="o">.</span><span class="n">logged_in</span> <span class="o">=</span> <span class="kc">True</span>
|
|
<span class="bp">self</span><span class="o">.</span><span class="n">sessionhandler</span><span class="o">.</span><span class="n">connect</span><span class="p">(</span><span class="bp">self</span><span class="o">.</span><span class="n">bot</span><span class="p">)</span>
|
|
|
|
<span class="c1"># start repeater task</span>
|
|
<span class="bp">self</span><span class="o">.</span><span class="n">bot</span><span class="o">.</span><span class="n">update</span><span class="p">(</span><span class="n">init</span><span class="o">=</span><span class="kc">True</span><span class="p">)</span>
|
|
<span class="bp">self</span><span class="o">.</span><span class="n">task</span> <span class="o">=</span> <span class="n">task</span><span class="o">.</span><span class="n">LoopingCall</span><span class="p">(</span><span class="bp">self</span><span class="o">.</span><span class="n">bot</span><span class="o">.</span><span class="n">update</span><span class="p">)</span>
|
|
<span class="k">if</span> <span class="bp">self</span><span class="o">.</span><span class="n">rate</span><span class="p">:</span>
|
|
<span class="bp">self</span><span class="o">.</span><span class="n">task</span><span class="o">.</span><span class="n">start</span><span class="p">(</span><span class="bp">self</span><span class="o">.</span><span class="n">rate</span><span class="p">,</span> <span class="n">now</span><span class="o">=</span><span class="kc">False</span><span class="p">)</span><span class="o">.</span><span class="n">addErrback</span><span class="p">(</span><span class="n">errback</span><span class="p">)</span></div></div>
|
|
</pre></div>
|
|
|
|
</div>
|
|
</div>
|
|
</div>
|
|
<div class="sphinxsidebar" role="navigation" aria-label="main navigation">
|
|
<div class="sphinxsidebarwrapper">
|
|
<p class="logo"><a href="../../../../index.html">
|
|
<img class="logo" src="../../../../_static/evennia_logo.png" alt="Logo"/>
|
|
</a></p>
|
|
<div id="searchbox" style="display: none" role="search">
|
|
<h3 id="searchlabel">Quick search</h3>
|
|
<div class="searchformwrapper">
|
|
<form class="search" action="../../../../search.html" method="get">
|
|
<input type="text" name="q" aria-labelledby="searchlabel" />
|
|
<input type="submit" value="Go" />
|
|
</form>
|
|
</div>
|
|
</div>
|
|
<script>$('#searchbox').show(0);</script>
|
|
<h3>Versions</h3>
|
|
<ul>
|
|
<li><a href="rss.html">1.0-dev (develop branch)</a></li>
|
|
<li><a href="../../../../../0.9.5/index.html">0.9.5 (master branch)</a></li>
|
|
</ul>
|
|
|
|
</div>
|
|
</div>
|
|
<div class="clearer"></div>
|
|
</div>
|
|
<div class="related" role="navigation" aria-label="related navigation">
|
|
<h3>Navigation</h3>
|
|
<ul>
|
|
<li class="right" style="margin-right: 10px">
|
|
<a href="../../../../genindex.html" title="General Index"
|
|
>index</a></li>
|
|
<li class="right" >
|
|
<a href="../../../../py-modindex.html" title="Python Module Index"
|
|
>modules</a> |</li>
|
|
<li class="nav-item nav-item-0"><a href="../../../../index.html">Evennia 1.0-dev</a> »</li>
|
|
<li class="nav-item nav-item-1"><a href="../../../index.html" >Module code</a> »</li>
|
|
<li class="nav-item nav-item-2"><a href="../../../evennia.html" >evennia</a> »</li>
|
|
</ul>
|
|
</div>
|
|
<div class="footer" role="contentinfo">
|
|
© Copyright 2020, The Evennia developer community.
|
|
Created using <a href="http://sphinx-doc.org/">Sphinx</a> 2.4.4.
|
|
</div>
|
|
</body>
|
|
</html> |