diff options
Diffstat (limited to 'db')
| -rw-r--r-- | db/upgrade.php | 131 |
1 files changed, 124 insertions, 7 deletions
diff --git a/db/upgrade.php b/db/upgrade.php index d47312d..5f34314 100644 --- a/db/upgrade.php +++ b/db/upgrade.php @@ -25,11 +25,93 @@ defined('MOODLE_INTERNAL') || die(); /** + * Create a table local_webhooks_events. + * + * @throws \ddl_exception + */ +function create_table_events() { + global $DB; + + // Loads ddl manager and xmldb classes. + $dbman = $DB->get_manager(); + + // Define table local_webhooks_events to be created. + $table = new xmldb_table('local_webhooks_events'); + + // Adding fields to table local_webhooks_events. + $table->add_field('id', XMLDB_TYPE_INTEGER, '10', null, XMLDB_NOTNULL, XMLDB_SEQUENCE, null); + $table->add_field('name', XMLDB_TYPE_CHAR, '255', null, XMLDB_NOTNULL, null, null); + $table->add_field('serviceid', XMLDB_TYPE_INTEGER, '10', null, XMLDB_NOTNULL, null, null); + + // Adding keys to table local_webhooks_events. + $table->add_key('primary', XMLDB_KEY_PRIMARY, array('id')); + + // Conditionally launch create table for local_webhooks_events. + if (!$dbman->table_exists($table)) { + $dbman->create_table($table); + } +} + +/** + * Delete table local_webhooks_service. + * + * @throws \ddl_exception + * @throws \ddl_table_missing_exception + */ +function drop_table_service() { + global $DB; + + // Loads ddl manager and xmldb classes. + $dbman = $DB->get_manager(); + + // Define table local_webhooks_service to be dropped. + $table = new xmldb_table('local_webhooks_service'); + + // Conditionally launch drop table for local_webhooks_service. + if ($dbman->table_exists($table)) { + $dbman->drop_table($table); + } +} + +/** + * Create a table local_webhooks_service. + * + * @throws \ddl_exception + */ +function create_table_service() { + global $DB; + + // Loads ddl manager and xmldb classes. + $dbman = $DB->get_manager(); + + // Define table local_webhooks_service to be created. + $table = new xmldb_table('local_webhooks_service'); + + // Adding fields to table local_webhooks_service. + $table->add_field('id', XMLDB_TYPE_INTEGER, '10', null, XMLDB_NOTNULL, XMLDB_SEQUENCE, null); + $table->add_field('header', XMLDB_TYPE_CHAR, '255', null, XMLDB_NOTNULL, null, 'application/json'); + $table->add_field('name', XMLDB_TYPE_CHAR, '255', null, XMLDB_NOTNULL, null, null); + $table->add_field('point', XMLDB_TYPE_CHAR, '255', null, XMLDB_NOTNULL, null, null); + $table->add_field('status', XMLDB_TYPE_INTEGER, '1', null, XMLDB_NOTNULL, null, '0'); + $table->add_field('token', XMLDB_TYPE_CHAR, '255', null, XMLDB_NOTNULL, null, null); + + // Adding keys to table local_webhooks_service. + $table->add_key('primary', XMLDB_KEY_PRIMARY, array('id')); + + // Conditionally launch create table for local_webhooks_service. + if (!$dbman->table_exists($table)) { + $dbman->create_table($table); + } +} + +/** * Function to upgrade 'local_webhooks'. * * @param int $oldversion * - * @return boolean + * @return bool + * @throws \ddl_exception + * @throws \ddl_table_missing_exception * @throws \dml_exception * @throws \downgrade_exception * @throws \upgrade_exception @@ -39,18 +121,53 @@ function xmldb_local_webhooks_upgrade($oldversion = 0) { /* Update from versions 3.* */ if ($oldversion < 2017112600 || $oldversion === 2018061900) { - $rs = $DB->get_recordset('local_webhooks_service', null, 'id', '*', 0, 0); + $records = $DB->get_records('local_webhooks_service', null, 'id', '*', 0, 0); + + $services = array(); - foreach ($rs as $record) { + foreach ($records as $record) { if (!empty($record->events)) { $record->events = unserialize(gzuncompress(base64_decode($record->events))); - // TODO: This method does not exist. - /* local_webhooks_update_record( $record ); */ + } + + $service = array( + 'name' => $record->title, + 'point' => $record->url, + 'status' => (bool) $record->enable, + 'token' => $record->token, + ); + + if ($record->type === 'json') { + $service['header'] = 'application/json'; + } else { + $service['header'] = 'application/x-www-form-urlencoded'; + } + + foreach ($record->events as $eventname => $eventStatus) { + if ((bool) $eventStatus) { + $service['events'][] = $eventname; + } + } + + $services[] = $service; + } + + /* Update structure */ + drop_table_service(); + create_table_events(); + create_table_service(); + + /* Saving records */ + foreach ($services as $service) { + $serviceid = $DB->insert_record('local_webhooks_service', (object) $service, true, false); + if ($serviceid && is_array($service['events'])) { + foreach ($service['events'] as $eventname) { + $DB->insert_record('local_webhooks_events', (object) array('name' => $eventname, 'serviceid' => $serviceid), true, false); + } } } - $rs->close(); - upgrade_plugin_savepoint(true, 2017112600, 'local', 'webhooks'); + upgrade_plugin_savepoint(true, 2018061900, 'local', 'webhooks'); } /* Update from version 4.0.0-rc.1 */ |