Streams/streams
Streams/streams
1
0
Fork 0
mirror of https://codeberg.org/streams/streams.git synced 2024-09-19 23:55:19 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Add column outq_log to outq for diagnostic info.

Browse source
This commit is contained in:
Mike Macgirvin 2022-08-31 09:11:19 +10:00
parent 9d38b06a2b
commit 4501ef6873
3 changed files with 39 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
Code/Lib/Queue.php
View file

@ -155,8 +155,8 @@ class Queue
$x = q( $x = q(
"insert into outq ( outq_hash, outq_account, outq_channel, outq_driver, outq_posturl, outq_async, outq_priority, "insert into outq ( outq_hash, outq_account, outq_channel, outq_driver, outq_posturl, outq_async, outq_priority,
outq_created, outq_updated, outq_scheduled, outq_notify, outq_msg ) outq_created, outq_updated, outq_scheduled, outq_notify, outq_msg, outq_log )
values ( '%s', %d, %d, '%s', '%s', %d, %d, '%s', '%s', '%s', '%s', '%s' )", values ( '%s', %d, %d, '%s', '%s', %d, %d, '%s', '%s', '%s', '%s', '%s', '' )",
dbesc($arr['hash']), dbesc($arr['hash']),
intval($arr['account_id']), intval($arr['account_id']),
intval($arr['channel_id']), intval($arr['channel_id']),

36
Code/Update/_1260.php Normal file
View file

@ -0,0 +1,36 @@
<?php
namespace Code\Update;
class _1260
{
public function run()
{
$default = ((ACTIVE_DBTYPE == DBTYPE_POSTGRES) ? " default ''" : '');
q("START TRANSACTION");
$r = q("ALTER TABLE outq ADD outq_log text NOT NULL $default");
if ($r) {
q("COMMIT");
return UPDATE_SUCCESS;
}
q("ROLLBACK");
return UPDATE_FAILED;
}
public function verify()
{
$columns = db_columns('outq');
if (in_array('outq_log', $columns)) {
return true;
}
return false;
}
}

2
boot.php
View file

@ -28,7 +28,7 @@ require_once('version.php');
define ( 'PLATFORM_NAME', 'streams' ); define ( 'PLATFORM_NAME', 'streams' );
define ( 'DB_UPDATE_VERSION', 1259 ); define ( 'DB_UPDATE_VERSION', 1260 );
define ( 'ZOT_REVISION', '11.0' ); define ( 'ZOT_REVISION', '11.0' );
define ( 'PLATFORM_ARCHITECTURE', 'zap' ); define ( 'PLATFORM_ARCHITECTURE', 'zap' );