WIP

Author: derhuerst

index.js

@@ -43,6 +43,38 @@ const convertGtfsToSql = async (pathToDb, files, opt = {}) => {
 	debug('deps', deps)
 
 	const tasks = { // file name -> [dep name]
+		// 'is_bcp_47_code': {
+		// 	dep: [],
+		// },
+		// 'is_timezone': {
+		// 	dep: [],
+		// },
+		// ...(tripsWithoutShapeId ? {} : {
+		// 	'shape_exists': {
+		// 		dep: [...deps.shape_exists],
+		// 	},
+		// }),
+
+		// // special handling of calendar/calendar_dates:
+		// // service_days relies on *both* calendar's & calendar_dates' tables to
+		// // be present, so we add mock tasks here. Each of these mock tasks get
+		// // replaced by a file-based one below if the file has been passed.
+		// 'calendar': {
+		// 	dep: [],
+		// },
+		// 'calendar_dates': {
+		// 	dep: [],
+		// },
+		// 'service_days': {
+		// 	dep: ['calendar', 'calendar_dates'],
+		// },
+
+		// // The arrivals_departures & connections views rely on frequencies' table
+		// // to be present, so we add a mock task here. It gets replaced by a
+		// // file-based one below if the file has been passed.
+		// 'frequencies': {
+		// 	dep: [...deps.frequencies],
+		// },
 	}
 
 	for (const file of files) {

lib/agency.js

@@ -16,7 +16,34 @@ CREATE TABLE "${opt.schema}".agency (
 )
 	`)
 
-	// todo
+// COPY "${opt.schema}".agency (
+// 	agency_id,
+// 	agency_name,
+// 	agency_url,
+// 	agency_timezone,
+// 	agency_lang,
+// 	agency_phone,
+// 	agency_fare_url,
+// 	agency_email
+// ) FROM STDIN csv;
+// `
+
+// const formatAgencyRow = (a) => {
+// 	return [
+// 		a.agency_id || null,
+// 		a.agency_name || null,
+// 		a.agency_url || null,
+// 		a.agency_timezone || null,
+// 		a.agency_lang || null,
+// 		a.agency_phone || null,
+// 		a.agency_fare_url || null,
+// 		a.agency_email || null,
+// 	]
+// }
+
+// const afterAll = `\
+// \\.
+// `
 }
 
 module.exports = importData

lib/deps.js

@@ -1,9 +1,87 @@
 'use strict'
 
 const getDependencies = (opt, files) => {
+	// const {
+	// 	tripsWithoutShapeId,
+	// 	routesWithoutAgencyId,
+	// 	stopsWithoutLevelId,
+	// } = opt
 	return {
+		// shape_exists: [
+		// 	'shapes',
+		// ],
 		agency: [
+			// 'is_timezone',
 		],
+		// stops: [
+		// 	'is_timezone',
+		// 	...(stopsWithoutLevelId ? [] : ['levels']),
+		// ],
+		// transfers: [
+		// 	'stops',
+		// ],
+		// stop_times: [
+		// 	'trips',
+		// 	'stops',
+		// 	'service_days',
+		// 	'frequencies',
+		// ],
+		// routes: [
+		// 	...(routesWithoutAgencyId ? [] : ['agency']),
+		// ],
+		// trips: [
+		// 	'routes',
+		// 	'service_days',
+		// 	...(tripsWithoutShapeId ? [] : ['shapes', 'shape_exists']),
+		// ],
+		// frequencies: [
+		// 	'trips',
+		// ],
+		// pathways: [
+		// 	'stops',
+		// ],
+		// feed_info: [
+		// 	'is_bcp_47_code',
+		// ],
+		// translations: [
+		// 	'is_bcp_47_code',
+		// 	// > table_name
+		// 	// > Defines the dataset table that contains the field to be translated. The following values are allowed:
+		// 	// > agency
+		// 	// > stops
+		// 	// > routes
+		// 	// > trips
+		// 	// > stop_times
+		// 	// > feed_info
+		// 	// > pathways
+		// 	// > levels
+		// 	// > attributions
+		// 	// https://developers.google.com/transit/gtfs/reference#translationstxt
+		// 	// todo: respect opt.*!
+		// 	// these are soft dependencies, they are not depended upon, they must only be imported first
+		// 	// todo: only specify dependencies here if the files are not in use
+		// 	'agency',
+		// 	'stops',
+		// 	'routes',
+		// 	'trips',
+		// 	...(files.includes('stop_times')
+		// 		? ['stop_times']
+		// 		: []
+		// 	),
+		// 	...(files.includes('feed_info')
+		// 		? ['feed_info']
+		// 		: []
+		// 	),
+		// 	...(files.includes('pathways')
+		// 		? ['pathways']
+		// 		: []
+		// 	),
+		// 	...(files.includes('levels')
+		// 		? ['levels']
+		// 		: []
+		// 	),
+		// 	// not supported yet: attributions
+		// ],
 	}
 }
 

lib/index.js

@@ -1,5 +1,22 @@
 'use strict'
 
 module.exports = {
+	// is_bcp_47_code: require('./prerequisites').is_bcp_47_code,
+	// is_timezone: require('./prerequisites').is_timezone,
+	// shape_exists: require('./prerequisites').shape_exists,
 	agency: require('./agency'),
+	// calendar: require('./calendar'),
+	// calendar_dates: require('./calendar_dates'),
+	// service_days: require('./service_days'),
+	// feed_info: require('./feed_info'),
+	// frequencies: require('./frequencies'),
+	// routes: require('./routes'),
+	// shapes: require('./shapes'),
+	// stop_times: require('./stop_times'),
+	// stops: require('./stops'),
+	// transfers: require('./transfers'),
+	// trips: require('./trips'),
+	// pathways: require('./pathways'),
+	// levels: require('./levels'),
+	// translations: require('./translations'),
 }