109 lines
3.1 KiB
PHP
109 lines
3.1 KiB
PHP
<?php
|
|
namespace activities;
|
|
|
|
function get_activity( $id ) {
|
|
global $wpdb;
|
|
$activity_json = $wpdb->get_var( $wpdb->prepare(
|
|
'SELECT activity FROM pterotype_activitypub_activities WHERE id = %d', $id
|
|
) );
|
|
if ( is_null( $activity_json ) ) {
|
|
return new \WP_Error(
|
|
'not_found', __( 'Activity not found', 'pterotype' ), array( 'status' => 404 )
|
|
);
|
|
}
|
|
$activity = json_decode( $activity_json, true );
|
|
return $activity;
|
|
}
|
|
|
|
function get_activity_by_activitypub_id( $activitypub_id ) {
|
|
global $wpdb;
|
|
$activity_json = $wpdb->get_var( $wpdb->prepare(
|
|
'SELECT activity FROM pterotype_activitypub_activities WHERE id = %s', $activitypub_id
|
|
) );
|
|
if ( is_null( $activity_json ) ) {
|
|
return new \WP_Error(
|
|
'not_found', __( 'Activity not found', 'pterotype' ), array( 'status' => 404 )
|
|
);
|
|
}
|
|
$activity = json_decode( $activity_json, true );
|
|
return $activity;
|
|
}
|
|
|
|
function strip_private_fields( $activity ) {
|
|
if ( array_key_exists( 'bto', $activity ) ) {
|
|
unset( $activity['bto'] );
|
|
}
|
|
if ( array_key_exists( 'bcc', $activity ) ) {
|
|
unset( $activity['bcc'] );
|
|
}
|
|
return $activity;
|
|
}
|
|
|
|
function persist_activity( $activity ) {
|
|
global $wpdb;
|
|
if ( !array_key_exists( 'id', $activity ) ) {
|
|
return new \WP_Error(
|
|
'invalid_activity',
|
|
__( 'Activity must have an "id" field', 'pterotype' ),
|
|
array( 'status' => 400 )
|
|
);
|
|
}
|
|
$activitypub_id = $activity['id'];
|
|
$wpdb->insert( 'pterotype_activitypub_activities', array(
|
|
'activitypub_id' => $activitypub_id,
|
|
'activity' => wp_json_encode( $activity )
|
|
) );
|
|
return $activity;
|
|
}
|
|
|
|
function create_local_activity( $activity ) {
|
|
global $wpdb;
|
|
$res = $wpdb->insert( 'pterotype_activitypub_activities', array(
|
|
'activity' => wp_json_encode( $activity )
|
|
) );
|
|
if ( !$res ) {
|
|
return new \WP_Error(
|
|
'db_error', __( 'Failed to insert activity row', 'pterotype' )
|
|
);
|
|
}
|
|
$activity_id = $wpdb->insert_id;
|
|
$activity_url = get_rest_url( null, sprintf( '/pterotype/v1/activity/%d', $id ) );
|
|
$activity['id'] = $activity_url;
|
|
$res = $wpdb->replace(
|
|
'pterotype_activitypub_activities',
|
|
array(
|
|
'id' => $activity_id,
|
|
'activitypub_id' => $activity_url,
|
|
'activity' => $activity
|
|
),
|
|
array( '%d', '%s', '%s' )
|
|
);
|
|
if ( !$res ) {
|
|
return new \WP_Error(
|
|
'db_error', __( 'Failed to hydrate activity id', 'pterotype' )
|
|
);
|
|
}
|
|
return $activity;
|
|
}
|
|
|
|
function create_activities_table() {
|
|
global $wpdb;
|
|
$wpdb->query(
|
|
"
|
|
CREATE TABLE IF NOT EXISTS pterotype_activitypub_activities (
|
|
id INT UNSIGNED AUTO_INCREMENT PRIMARY KEY,
|
|
activitypub_id VARCHAR(255) UNIQUE NOT NULL,
|
|
activity TEXT NOT NULL
|
|
)
|
|
ENGINE=InnoDB DEFAULT CHARSET=utf8;
|
|
"
|
|
);
|
|
$wpdb->query(
|
|
"
|
|
CREATE UNIQUE INDEX ACTIVITIES_ACTIVITYPUB_ID_INDEX
|
|
ON pterotype_activitypub_activities (activitypub_id);
|
|
"
|
|
);
|
|
}
|
|
?>
|