diff --git a/newspack-custom-content-migrator.php b/newspack-custom-content-migrator.php
index 3fa227e2b..412bf42b2 100644
--- a/newspack-custom-content-migrator.php
+++ b/newspack-custom-content-migrator.php
@@ -84,5 +84,6 @@
 		Command\PublisherSpecific\CarsonNowMigrator::class,
 		Command\PublisherSpecific\ArkansasTimesMigrator::class,
 		Command\PublisherSpecific\ZocaloMigrator::class,
+		Command\PublisherSpecific\StandardMigrationTestMigrator::class,
 	)
 );
diff --git a/src/Command/PublisherSpecific/StandardMigrationTestMigrator.php b/src/Command/PublisherSpecific/StandardMigrationTestMigrator.php
new file mode 100644
index 000000000..210028a77
--- /dev/null
+++ b/src/Command/PublisherSpecific/StandardMigrationTestMigrator.php
@@ -0,0 +1,109 @@
+<?php
+
+namespace NewspackCustomContentMigrator\Command\PublisherSpecific;
+
+use NewspackCustomContentMigrator\Command\InterfaceCommand;
+use NewspackCustomContentMigrator\Migrator\AbstractMigrationRun;
+use NewspackCustomContentMigrator\Migrator\JSONMigrationObjectsClass;
+use NewspackCustomContentMigrator\Migrator\MigrationObjects;
+
+class StandardMigrationTestMigrator implements InterfaceCommand {
+
+	private static $instance = null;
+
+	public static function get_instance() {
+		$class = get_called_class();
+		if ( null === self::$instance ) {
+			self::$instance = new $class();
+		}
+
+		return self::$instance;
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function register_commands() {
+		\WP_CLI::add_command(
+			'newspack-content-migrator execute-user-migration',
+			[ $this, 'execute_user_migration' ],
+			[
+				'shortdesc' => 'Executes the user migration.',
+				'synopsis'  => [
+					[
+						'type'        => 'assoc',
+						'name'        => 'path-to-json',
+						'description' => 'The JSON to migrate',
+						'optional'    => false,
+					],
+				],
+			]
+		);
+	}
+
+	public function execute_user_migration( $args, $assoc_args ) {
+		( new class( $args, $assoc_args ) extends AbstractMigrationRun {
+
+			public function __construct( $args, $assoc_args ) {
+				$this->args       = $args;
+				$this->assoc_args = $assoc_args;
+
+				$this->set_name( 'User Migration' );
+			}
+
+			/**
+			 * Returns the migration objects.
+			 *
+			 * @return MigrationObjects
+			 */
+			public function get_migration_objects(): MigrationObjects {
+				return new JSONMigrationObjectsClass( $this->get_run_key(), $this->assoc_args['path-to-json'] );
+			}
+
+			/**
+			 * This function houses the logic for the command.
+			 *
+			 * @param MigrationObjects $migration_objects The objects to perform the migration on.
+			 *
+			 * @return bool|\WP_Error
+			 * @throws \Exception If an error occurs.
+			 */
+			public function command( MigrationObjects $migration_objects ): bool|\WP_Error {
+				foreach ( $migration_objects->get_unprocessed() as $migration_object ) {
+					$user_data = [
+						'user_pass' => wp_generate_password( 12 ),
+					];
+
+					if ( is_email( $migration_object->get()['user_login'] ) ) {
+						$user_data['user_login'] = substr( $migration_object->get()['user_login'], 0, strpos( $migration_object->get()['user_login'], '@' ) );
+					} else {
+						$user_data['user_login'] = $migration_object->get()['user_login'];
+					}
+
+					$user_data['user_email'] = $migration_object->get()['user_email'];
+
+					$user_data['display_name'] = $migration_object->get()['user_name'] . ' ' . $migration_object->get()['user_lastname'];
+
+					$user_data['user_nicename'] = sanitize_title( $user_data['display_name'] );
+
+					$user_id = wp_insert_user( $user_data );
+
+					if ( is_wp_error( $user_id ) ) {
+						\WP_CLI::error( 'Failed to insert user: ' . $user_id->get_error_message() );
+						return false;
+					} else {
+						\WP_CLI::success( 'Inserted user: ' . $user_data['user_login'] );
+						$migration_object->record_source( 'wp_users', 'user_login', $user_id, 'user_login' );
+						$migration_object->record_source( 'wp_users', 'user_email', $user_id, 'user_email' );
+						$migration_object->record_source( 'wp_users', 'display_name', $user_id, 'user_name' );
+						$migration_object->record_source( 'wp_users', 'display_name', $user_id, 'user_lastname' );
+						$migration_object->record_source( 'wp_users', 'user_nicename', $user_id, 'wp_users.display_name' );
+						$migration_object->store_processed_marker();
+					}
+				}
+
+				return true;
+			}
+		} )->start();
+	}
+}
diff --git a/src/Migrator/AbstractMigrationObject.php b/src/Migrator/AbstractMigrationObject.php
new file mode 100644
index 000000000..24454a5b2
--- /dev/null
+++ b/src/Migrator/AbstractMigrationObject.php
@@ -0,0 +1,159 @@
+<?php
+
+namespace NewspackCustomContentMigrator\Migrator;
+
+use NewspackCustomContentMigrator\Migrator\MigrationObject;
+
+abstract class AbstractMigrationObject implements MigrationObject {
+
+	protected MigrationRunKey $run_key;
+
+	protected object|array $data;
+
+	protected string $pointer_to_identifier;
+
+	protected bool $processed;
+
+	private \wpdb $wpdb;
+
+	public function __construct( MigrationRunKey $run_key ) {
+		$this->run_key = $run_key;
+		global $wpdb;
+		$this->wpdb = $wpdb;
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function set_run_key( MigrationRunKey $run_key ): void {
+		// TODO: Implement set_run_key() method.
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function get_run_key(): MigrationRunKey {
+		return $this->run_key;
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function set( object|array $data, string $pointer_to_identifier = 'id' ): void {
+		$this->data                  = $data;
+		$this->pointer_to_identifier = $pointer_to_identifier;
+		// TODO setting of $processed could be improved by using a cache
+		$this->has_been_processed();
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function get(): array|object {
+		return $this->data;
+	}
+
+	/**
+	 * @return string
+	 */
+	public function get_pointer_to_identifier(): string {
+		return $this->pointer_to_identifier;
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function store(): bool {
+		$insert = $this->wpdb->insert(
+			$this->wpdb->options,
+			[
+				'option_name'  => $this->get_run_key()->get() . '_migration_object_' . $this->get() [ $this->get_pointer_to_identifier() ],
+				'option_value' => wp_json_encode( $this->get() ),
+				'autoload'     => 'no',
+			]
+		);
+
+		if ( ! is_bool( $insert ) ) {
+			return false;
+		}
+
+		return $insert;
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function store_processed_marker(): bool {
+		$insert = $this->wpdb->insert(
+			$this->wpdb->options,
+			[
+				'option_name'  => $this->get_run_key()->get() . '_migration_object_' . $this->get()[ $this->get_pointer_to_identifier() ] . '_processed',
+				'option_value' => '1',
+				'autoload'     => 'no',
+			]
+		);
+
+		if ( ! is_bool( $insert ) ) {
+			return false;
+		}
+
+		if ( $insert ) {
+			$this->processed = true;
+		}
+
+		return $insert;
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function has_been_processed(): bool {
+		if ( ! isset( $this->processed ) ) {
+			// phpcs:disable
+			$options_table = $this->wpdb->options;
+			$this->processed = (bool) $this->wpdb->get_var(
+				$this->wpdb->prepare(
+					"SELECT option_value FROM {$options_table} WHERE option_name = %s",
+					$this->get_run_key()->get() . '_migration_object_' . $this->get()[ $this->get_pointer_to_identifier() ] . '_processed'
+				)
+			);
+			// phpcs:enable
+		}
+
+		return $this->processed;
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function record_source( string $table, string $column, int $id, string $source ): bool {
+		$meta_table = match ( $table ) {
+			'wp_users' => $this->wpdb->usermeta,
+			'wp_posts' => $this->wpdb->postmeta,
+			'wp_terms' => $this->wpdb->termmeta,
+			default    => $this->wpdb->options,
+		};
+
+		$option_name = $this->get_run_key()->get() . '_migration_object_source_' . $this->get()[ $this->get_pointer_to_identifier() ] . "_{$table}_{$column}_{$id}";
+		$insert      = $this->wpdb->insert(
+			$meta_table,
+			[
+				'meta_key'   => $option_name,
+				'meta_value' => wp_json_encode(
+					[
+						'table'  => $table,
+						'column' => $column,
+						'id'     => $id,
+						'source' => $source,
+					]
+				),
+			]
+		);
+
+		if ( ! is_bool( $insert ) ) {
+			return false;
+		}
+
+		return $insert;
+	}
+}
diff --git a/src/Migrator/AbstractMigrationObjects.php b/src/Migrator/AbstractMigrationObjects.php
new file mode 100644
index 000000000..75f358665
--- /dev/null
+++ b/src/Migrator/AbstractMigrationObjects.php
@@ -0,0 +1,57 @@
+<?php
+
+namespace NewspackCustomContentMigrator\Migrator;
+
+use NewspackCustomContentMigrator\Migrator\MigrationObjects;
+
+abstract class AbstractMigrationObjects implements MigrationObjects {
+
+	private MigrationRunKey $run_key;
+
+	protected iterable $data;
+
+	public function __construct( iterable $data, MigrationRunKey $run_key ) {
+		$this->data    = $data;
+		$this->run_key = $run_key;
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function set_run_key( MigrationRunKey $run_key ): void {
+		$this->run_key = $run_key;
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function get_run_key(): MigrationRunKey {
+		return $this->run_key;
+	}
+
+	/**
+	 * Returns all processed migration objects.
+	 *
+	 * @return MigrationObject[]
+	 */
+	public function get_processed(): iterable {
+		foreach ( $this->get_all() as $migration_object ) {
+			if ( $migration_object->has_been_processed() ) {
+				yield $migration_object;
+			}
+		}
+	}
+
+	/**
+	 * Returns all unprocessed migration objects.
+	 *
+	 * @return MigrationObject[]
+	 */
+	public function get_unprocessed(): iterable {
+		foreach ( $this->get_all() as $migration_object ) {
+			if ( ! $migration_object->has_been_processed() ) {
+				yield $migration_object;
+			}
+		}
+	}
+}
\ No newline at end of file
diff --git a/src/Migrator/AbstractMigrationRun.php b/src/Migrator/AbstractMigrationRun.php
new file mode 100644
index 000000000..156dbc93f
--- /dev/null
+++ b/src/Migrator/AbstractMigrationRun.php
@@ -0,0 +1,73 @@
+<?php
+
+namespace NewspackCustomContentMigrator\Migrator;
+
+use NewspackCustomContentMigrator\Migrator\MigrationRun;
+
+abstract class AbstractMigrationRun implements MigrationRun {
+
+	protected $name;
+
+	protected FinalMigrationRunKey $run_key;
+
+	/**
+	 * @inheritDoc
+	 */
+	public function get_application_key(): string {
+		return '_data_migration';
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function set_name( string $name ): void {
+		$this->name = sanitize_title( $name );
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function get_name(): string {
+		return $this->name;
+	}
+
+	/**
+	 * @inheritDoc
+	 *
+	 * @throws \Exception If an error occurs.
+	 */
+	public function start(): void {
+		$this->command( $this->get_migration_objects() );
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function resume(): void {
+		// TODO: Implement resume() method.
+	}
+
+	/**
+	 * @inheritDoc
+	 *
+	 * @throws \Exception If an error occurs.
+	 */
+	public function restart(): void {
+		$this->cancel( false );
+		$this->start();
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function cancel( bool $delete_data ): void {
+		// TODO: Implement cancel() method.
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function get_run_key(): FinalMigrationRunKey {
+		return new FinalMigrationRunKey( $this->get_name() . '1' );
+	}
+}
\ No newline at end of file
diff --git a/src/Migrator/FinalMigrationRunKey.php b/src/Migrator/FinalMigrationRunKey.php
new file mode 100644
index 000000000..d6beb1846
--- /dev/null
+++ b/src/Migrator/FinalMigrationRunKey.php
@@ -0,0 +1,19 @@
+<?php
+
+namespace NewspackCustomContentMigrator\Migrator;
+
+final class FinalMigrationRunKey implements MigrationRunKey {
+
+	private $run_key;
+
+	public function __construct( string $run_key ) {
+		$this->run_key = $run_key;
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function get(): string {
+		return $this->run_key;
+	}
+}
\ No newline at end of file
diff --git a/src/Migrator/JSONMigrationObject.php b/src/Migrator/JSONMigrationObject.php
new file mode 100644
index 000000000..57db16876
--- /dev/null
+++ b/src/Migrator/JSONMigrationObject.php
@@ -0,0 +1,13 @@
+<?php
+
+namespace NewspackCustomContentMigrator\Migrator;
+
+interface JSONMigrationObject extends MigrationObject {
+
+	/**
+	 * Gets the JSON attribute pointer that can be used to uniquely identify a JSON object.
+	 *
+	 * @return string
+	 */
+	public function get_pointer_to_identifier(): string;
+}
\ No newline at end of file
diff --git a/src/Migrator/JSONMigrationObjects.php b/src/Migrator/JSONMigrationObjects.php
new file mode 100644
index 000000000..206add400
--- /dev/null
+++ b/src/Migrator/JSONMigrationObjects.php
@@ -0,0 +1,23 @@
+<?php
+
+namespace NewspackCustomContentMigrator\Migrator;
+
+interface JSONMigrationObjects extends MigrationObjects {
+
+	/**
+	 * Saves the migration JSON to DB.
+	 *
+	 * @param string $full_path The full local path to the migration JSON.
+	 * @param string $pointer_to_identifier The JSON attribute pointer that can be used to uniquely identify a JSON object.
+	 *
+	 * @return bool
+	 */
+	public function save( string $full_path, string $pointer_to_identifier = 'id' ): bool;
+
+	/**
+	 * Gets the JSON attribute pointer that can be used to uniquely identify a JSON object.
+	 *
+	 * @return string
+	 */
+	public function get_pointer_to_identifier(): string;
+}
\ No newline at end of file
diff --git a/src/Migrator/JSONMigrationObjectsClass.php b/src/Migrator/JSONMigrationObjectsClass.php
new file mode 100644
index 000000000..553b9a443
--- /dev/null
+++ b/src/Migrator/JSONMigrationObjectsClass.php
@@ -0,0 +1,142 @@
+<?php
+
+namespace NewspackCustomContentMigrator\Migrator;
+
+use Exception;
+use NewspackCustomContentMigrator\Utils\CommonDataFileIterator\FileImportFactory;
+
+class JSONMigrationObjectsClass extends AbstractMigrationObjects implements JSONMigrationObjects {
+
+	const MIGRATION_JSON_FILE_KEY                       = 'migration_json_file';
+	const MIGRATION_JSON_FILE_PATH_KEY                  = 'migration_json_file_path';
+	const MIGRATION_JSON_FILE_POINTER_TO_IDENTIFIER_KEY = 'migration_json_file_pointer_to_identifier';
+
+	protected string $path_to_json_file;
+
+	protected string $pointer_to_identifier;
+
+	/**
+	 * @throws Exception
+	 */
+	public function __construct( MigrationRunKey $run_key, string $path_to_json_file, string $pointer_to_identifier = 'id' ) {
+		parent::__construct( [], $run_key );
+
+		$result = $this->save( $path_to_json_file, $pointer_to_identifier );
+
+		if ( ! $result ) {
+			throw new Exception( 'Failed to save JSON migration objects.' );
+		}
+	}
+
+	/**
+	 * Saves the migration JSON to DB.
+	 *
+	 * @param string $full_path The full local path to the migration JSON.
+	 * @param string $pointer_to_identifier The JSON attribute pointer that can be used to uniquely identify a JSON object.
+	 *
+	 * @return bool
+	 */
+	public function save( string $full_path, string $pointer_to_identifier = 'id' ): bool {
+		if ( ! file_exists( $full_path ) ) {
+			return false;
+		}
+
+		$meta = [
+			[
+				'option_name'  => $this->get_run_key()->get() . '_' . self::MIGRATION_JSON_FILE_PATH_KEY,
+				'option_value' => $full_path,
+				'autoload'     => 'no',
+			],
+			[
+				'option_name'  => $this->get_run_key()->get() . '_' . self::MIGRATION_JSON_FILE_POINTER_TO_IDENTIFIER_KEY,
+				'option_value' => $pointer_to_identifier,
+				'autoload'     => 'no',
+			],
+		];
+
+		global $wpdb;
+
+		foreach ( $meta as $meta_item ) {
+			extract( $meta_item );
+			$option_exists = $wpdb->get_row(
+				$wpdb->prepare(
+					"SELECT * FROM $wpdb->options WHERE option_name = %s",
+					$option_name
+				)
+			);
+
+			if ( $option_exists ) {
+				if ( $option_exists->option_value !== $option_value ) {
+					// TODO - trying to reuse migration run with new params. Either new params should be ignored or new migration run is required.
+					return false;
+				} else {
+					continue;
+				}
+			} else {
+				// phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery
+				$wpdb->insert( $wpdb->options, $meta_item );
+			}
+		}
+
+		$this->path_to_json_file     = $full_path;
+		$this->pointer_to_identifier = $pointer_to_identifier;
+
+		return true;
+	}
+
+	/**
+	 * Gets the JSON attribute pointer that can be used to uniquely identify a JSON object.
+	 *
+	 * @return string
+	 */
+	public function get_pointer_to_identifier(): string {
+		if ( ! isset( $this->pointer_to_identifier ) ) {
+			global $wpdb;
+
+			// phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching
+			$pointer_to_identifier = $wpdb->get_var(
+				$wpdb->prepare(
+					"SELECT option_value FROM {$wpdb->options} WHERE option_name = %s",
+					$this->get_run_key()->get() . '_' . self::MIGRATION_JSON_FILE_POINTER_TO_IDENTIFIER_KEY
+				)
+			);
+
+			if ( ! $pointer_to_identifier ) {
+				$pointer_to_identifier = 'id';
+			}
+
+			$this->pointer_to_identifier = $pointer_to_identifier;
+		}
+
+		return $this->pointer_to_identifier;
+	}
+
+	/**
+	 * Gets all migration objects.
+	 *
+	 * @return MigrationObject[]
+	 */
+	public function get_all(): iterable {
+		if ( ! isset( $this->path_to_json_file ) ) {
+			global $wpdb;
+
+			// phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching
+			$path_to_json_file = $wpdb->get_var(
+				$wpdb->prepare(
+					"SELECT option_value FROM {$wpdb->options} WHERE option_name = %s",
+					$this->get_run_key()->get() . '_' . self::MIGRATION_JSON_FILE_PATH_KEY
+				)
+			);
+
+			if ( ! $path_to_json_file ) {
+				return [];
+			}
+
+			$this->path_to_json_file = $path_to_json_file;
+		}
+
+		foreach ( ( new FileImportFactory() )->get_file( $this->path_to_json_file )->getIterator() as $json_object ) {
+			yield new MigrationObjectClass( $this->get_run_key(), $json_object, $this->get_pointer_to_identifier() );
+		}
+	}
+}
diff --git a/src/Migrator/MigrationCommand.php b/src/Migrator/MigrationCommand.php
new file mode 100644
index 000000000..7e686b671
--- /dev/null
+++ b/src/Migrator/MigrationCommand.php
@@ -0,0 +1,39 @@
+<?php
+
+namespace NewspackCustomContentMigrator\Migrator;
+
+interface MigrationCommand {
+
+	/**
+	 * Returns the application key. This is a unique key that identifies this implementation in the WordPress options table.
+	 *
+	 * @return string
+	 */
+	public function get_application_key(): string;
+
+	/**
+	 * Sets the name of this particular command.
+	 *
+	 * @param string $name Command name.
+	 *
+	 * @return void
+	 */
+	public function set_name( string $name ): void;
+
+	/**
+	 * Returns the name of this particular command.
+	 *
+	 * @return string
+	 */
+	public function get_name(): string;
+
+	/**
+	 * This function houses the logic for the command.
+	 *
+	 * @param MigrationObjects $migration_objects The objects to perform the migration on.
+	 *
+	 * @return bool|\WP_Error
+	 * @throws \Exception If an error occurs.
+	 */
+	public function command( MigrationObjects $migration_objects ): bool|\WP_Error;
+}
\ No newline at end of file
diff --git a/src/Migrator/MigrationObject.php b/src/Migrator/MigrationObject.php
new file mode 100644
index 000000000..c7f7215f4
--- /dev/null
+++ b/src/Migrator/MigrationObject.php
@@ -0,0 +1,79 @@
+<?php
+
+namespace NewspackCustomContentMigrator\Migrator;
+
+interface MigrationObject {
+
+	/**
+	 * Sets a key which identifies a specific version of a migration run.
+	 *
+	 * @param MigrationRunKey $run_key Migration run key.
+	 *
+	 * @return void
+	 */
+	public function set_run_key( MigrationRunKey $run_key ): void;
+
+	/**
+	 * Returns the migration run key.
+	 *
+	 * @return MigrationRunKey
+	 */
+	public function get_run_key(): MigrationRunKey;
+
+	/**
+	 * Gets the pointer to the property that uniquely identifies a migration object.
+	 *
+	 * @return string
+	 */
+	public function get_pointer_to_identifier(): string;
+
+	/**
+	 * Sets the data to be migrated.
+	 *
+	 * @param array|object $data Data to be migrated.
+	 *
+	 * @return void
+	 */
+	public function set( array|object $data ): void;
+
+	/**
+	 * Gets the data to be migrated.
+	 *
+	 * @return array|object
+	 */
+	public function get(): array|object;
+
+	/**
+	 * Stores the object in the database.
+	 *
+	 * @return bool
+	 */
+	public function store(): bool;
+
+	/**
+	 * Marks the object as processed.
+	 *
+	 * @return bool
+	 */
+	public function store_processed_marker(): bool;
+
+	/**
+	 * Returns whether the object has been processed.
+	 *
+	 * @return bool
+	 */
+	public function has_been_processed(): bool;
+
+	/**
+	 * This function provides an auditing mechanism for the migration process. This should be used if you would
+	 * like to keep track of the source for a particular piece of data.
+	 *
+	 * @param string $table Table where the data is stored.
+	 * @param string $column Column where the data is stored.
+	 * @param int    $id ID of the row.
+	 * @param string $source Source of the data.
+	 *
+	 * @return bool
+	 */
+	public function record_source( string $table, string $column, int $id, string $source ): bool;
+}
\ No newline at end of file
diff --git a/src/Migrator/MigrationObjectClass.php b/src/Migrator/MigrationObjectClass.php
new file mode 100644
index 000000000..db3d24943
--- /dev/null
+++ b/src/Migrator/MigrationObjectClass.php
@@ -0,0 +1,13 @@
+<?php
+
+namespace NewspackCustomContentMigrator\Migrator;
+
+use NewspackCustomContentMigrator\Migrator\AbstractMigrationObject;
+
+class MigrationObjectClass extends AbstractMigrationObject {
+
+	public function __construct( MigrationRunKey $run_key, object|array $data, string $pointer_to_identifier = 'id' ) {
+		parent::__construct( $run_key );
+		$this->set( $data, $pointer_to_identifier );
+	}
+}
\ No newline at end of file
diff --git a/src/Migrator/MigrationObjects.php b/src/Migrator/MigrationObjects.php
new file mode 100644
index 000000000..920f1d415
--- /dev/null
+++ b/src/Migrator/MigrationObjects.php
@@ -0,0 +1,41 @@
+<?php
+
+namespace NewspackCustomContentMigrator\Migrator;
+
+interface MigrationObjects {
+
+	/**
+	 * Sets the migration run key.
+	 *
+	 * @param MigrationRunKey $run_key Migration run key.
+	 */
+	public function set_run_key( MigrationRunKey $run_key ): void;
+
+	/**
+	 * Gets the migration run key.
+	 *
+	 * @return MigrationRunKey
+	 */
+	public function get_run_key(): MigrationRunKey;
+
+	/**
+	 * Gets all migration objects.
+	 *
+	 * @return MigrationObject[]
+	 */
+	public function get_all(): iterable;
+
+	/**
+	 * Gets all processed migration objects.
+	 *
+	 * @return MigrationObject[]
+	 */
+	public function get_processed(): iterable;
+
+	/**
+	 * Gets all unprocessed migration objects.
+	 *
+	 * @return MigrationObject[]
+	 */
+	public function get_unprocessed(): iterable;
+}
\ No newline at end of file
diff --git a/src/Migrator/MigrationRun.php b/src/Migrator/MigrationRun.php
new file mode 100644
index 000000000..50f0c1b11
--- /dev/null
+++ b/src/Migrator/MigrationRun.php
@@ -0,0 +1,50 @@
+<?php
+
+namespace NewspackCustomContentMigrator\Migrator;
+
+interface MigrationRun extends MigrationCommand {
+
+	/**
+	 * Starts the migration run.
+	 *
+	 * @return void
+	 */
+	public function start(): void;
+
+	/**
+	 * Resumes the migration run if it has been interrupted.
+	 *
+	 * @return void
+	 */
+	public function resume(): void;
+
+	/**
+	 * Restarts the migration run. This will delete all data and start from scratch.
+	 *
+	 * @return void
+	 */
+	public function restart(): void;
+
+	/**
+	 * Cancels the migration run.
+	 *
+	 * @param bool $delete_data Whether to delete the data that has been migrated.
+	 *
+	 * @return void
+	 */
+	public function cancel( bool $delete_data ): void;
+
+	/**
+	 * Returns the migration run key.
+	 *
+	 * @return MigrationRunKey
+	 */
+	public function get_run_key(): MigrationRunKey;
+
+	/**
+	 * Returns the migration objects.
+	 *
+	 * @return MigrationObjects
+	 */
+	public function get_migration_objects(): MigrationObjects;
+}
\ No newline at end of file
diff --git a/src/Migrator/MigrationRunKey.php b/src/Migrator/MigrationRunKey.php
new file mode 100644
index 000000000..22a2d4bfc
--- /dev/null
+++ b/src/Migrator/MigrationRunKey.php
@@ -0,0 +1,13 @@
+<?php
+
+namespace NewspackCustomContentMigrator\Migrator;
+
+interface MigrationRunKey {
+
+	/**
+	 * Returns the migration run key.
+	 *
+	 * @return string
+	 */
+	public function get(): string;
+}
\ No newline at end of file