Live replication not working between two servers

[hadrien-toma]

Hello folks,

While running the following two pouchdb-servers, the initial state of localhost:4444/local database is well replicated to localhost:5555/local but then, when I add a document in localhost:4444/local via fauxton, it is not replicated... Does someone have an idea why?

• localhost:4444:

import * as express from 'express';
import * as expressPouchDB from 'express-pouchdb';
import * as PouchDBStatic from 'pouchdb';

const envs = {
	admin: {
		password: 'cloud',
		username: 'cloud'
	},
	databases: {
		local: {
			auth: {
				username: 'cloud',
				password: 'cloud'
			},
			subPath: '.dbs/cloud/'
		}
	},
	port: 4444,
	subPath: '.dbs/cloud/'
};
const prefix = `${process.env.INIT_CWD}/${envs.subPath}`;

const app = express();

const pouchdbOnFs = PouchDBStatic.defaults({ prefix });
const expressPouchdbOptions = {
	configPath: `${prefix}/config.json`,
	logPath: `${prefix}/log.txt`
};
const pouchdbOnFsHandle = expressPouchDB(pouchdbOnFs, expressPouchdbOptions);

pouchdbOnFsHandle.couchConfig.set('admins', envs.admin.username, envs.admin.password, (error) => {
	console.log('cloud', "couchConfig.set('admins', ...)", { error });
});

app.use('', pouchdbOnFsHandle);

const localDatabase = new PouchDBStatic<any>('local', {
	prefix: envs.databases['local'].subPath,
	auth: envs.databases['local'].auth
});

localDatabase
	.put<any>({ _id: 'en', flag: '🇬🇧' })
	.then(({ id, ok, rev }) => {
		console.log('cloud', 'localDatabase', 'put', 'then', { _id: id, ok, rev });
	})
	.catch((error) => {
		console.error('localDatabase', 'put', 'catch', { error });
	});

const server = app.listen(envs.port);

server.on('error', (error) => {
	console.log('cloud', 'server', 'error', { error });
});

• localhost:5555:

import * as express from 'express';
import * as expressPouchDB from 'express-pouchdb';
import * as PouchDBStatic from 'pouchdb';

const envs = {
	admin: {
		password: 'device',
		username: 'device'
	},
	databases: {
		local: {
			auth: {
				username: 'device',
				password: 'device'
			},
			subPath: '.dbs/device/'
		},
		remote: {
			name: 'http://localhost:4444/local',
			options: {
				auth: {
					username: 'cloud',
					password: 'cloud'
				}
			}
		}
	},
	port: 5555,
	subPath: '.dbs/device/'
};
const prefix = `${process.env.INIT_CWD}/${envs.subPath}`;

const app = express();

const pouchdbOnFs = PouchDBStatic.defaults({ prefix });
const expressPouchdbOptions = {
	configPath: `${prefix}/config.json`,
	logPath: `${prefix}/log.txt`
};
const pouchdbOnFsHandle = expressPouchDB(pouchdbOnFs, expressPouchdbOptions);

pouchdbOnFsHandle.couchConfig.set('admins', envs.admin.username, envs.admin.password, (error) => {
	console.log('device', "couchConfig.set('admins', ...)", { error });
});

app.use('', pouchdbOnFsHandle);

const databases: { [key: string]: PouchDB.Database<any> } = {};

databases['local'] = new PouchDBStatic<any>('local', {
	prefix: envs.databases['local'].subPath
});
databases['remote'] = new PouchDBStatic<any>(envs.databases['remote'].name, envs.databases['remote'].options);

databases['local'].replicate.from(databases['remote'], { live: true, retry: true });

const server = app.listen(envs.port);

server.on('error', (error) => {
	console.log('device', 'server', 'error', { error });
});

[BillMeyerRSA]

Hello folks,

While running the following two pouchdb-servers, the initial state of localhost:4444/local database is well replicated to localhost:5555/local but then, when I add a document in localhost:4444/local via fauxton, it is not replicated... Does someone have an idea why?

• localhost:4444:

import * as express from 'express';
import * as expressPouchDB from 'express-pouchdb';
import * as PouchDBStatic from 'pouchdb';

const envs = {
	admin: {
		password: 'cloud',
		username: 'cloud'
	},
	databases: {
		local: {
			auth: {
				username: 'cloud',
				password: 'cloud'
			},
			subPath: '.dbs/cloud/'
		}
	},
	port: 4444,
	subPath: '.dbs/cloud/'
};
const prefix = `${process.env.INIT_CWD}/${envs.subPath}`;

const app = express();

const pouchdbOnFs = PouchDBStatic.defaults({ prefix });
const expressPouchdbOptions = {
	configPath: `${prefix}/config.json`,
	logPath: `${prefix}/log.txt`
};
const pouchdbOnFsHandle = expressPouchDB(pouchdbOnFs, expressPouchdbOptions);

pouchdbOnFsHandle.couchConfig.set('admins', envs.admin.username, envs.admin.password, (error) => {
	console.log('cloud', "couchConfig.set('admins', ...)", { error });
});

app.use('', pouchdbOnFsHandle);

const localDatabase = new PouchDBStatic<any>('local', {
	prefix: envs.databases['local'].subPath,
	auth: envs.databases['local'].auth
});

localDatabase
	.put<any>({ _id: 'en', flag: '🇬🇧' })
	.then(({ id, ok, rev }) => {
		console.log('cloud', 'localDatabase', 'put', 'then', { _id: id, ok, rev });
	})
	.catch((error) => {
		console.error('localDatabase', 'put', 'catch', { error });
	});

const server = app.listen(envs.port);

server.on('error', (error) => {
	console.log('cloud', 'server', 'error', { error });
});

• localhost:5555:

import * as express from 'express';
import * as expressPouchDB from 'express-pouchdb';
import * as PouchDBStatic from 'pouchdb';

const envs = {
	admin: {
		password: 'device',
		username: 'device'
	},
	databases: {
		local: {
			auth: {
				username: 'device',
				password: 'device'
			},
			subPath: '.dbs/device/'
		},
		remote: {
			name: 'http://localhost:4444/local',
			options: {
				auth: {
					username: 'cloud',
					password: 'cloud'
				}
			}
		}
	},
	port: 5555,
	subPath: '.dbs/device/'
};
const prefix = `${process.env.INIT_CWD}/${envs.subPath}`;

const app = express();

const pouchdbOnFs = PouchDBStatic.defaults({ prefix });
const expressPouchdbOptions = {
	configPath: `${prefix}/config.json`,
	logPath: `${prefix}/log.txt`
};
const pouchdbOnFsHandle = expressPouchDB(pouchdbOnFs, expressPouchdbOptions);

pouchdbOnFsHandle.couchConfig.set('admins', envs.admin.username, envs.admin.password, (error) => {
	console.log('device', "couchConfig.set('admins', ...)", { error });
});

app.use('', pouchdbOnFsHandle);

const databases: { [key: string]: PouchDB.Database<any> } = {};

databases['local'] = new PouchDBStatic<any>('local', {
	prefix: envs.databases['local'].subPath
});
databases['remote'] = new PouchDBStatic<any>(envs.databases['remote'].name, envs.databases['remote'].options);

databases['local'].replicate.from(databases['remote'], { live: true, retry: true });

const server = app.listen(envs.port);

server.on('error', (error) => {
	console.log('device', 'server', 'error', { error });
});

Were you able to figure out how to do this? Having similar issues.

[hadrien-toma]

Nop, I am still blocked on this part...